Spring For Apache Kafka 2.1.0 和 1.3.2 发布

@SpringBootApplication  public class Kafka21Application {        public static void main(String[] args) {          SpringApplication.run(Kafka21Application.class, args)              .close();      }        @Bean      public ApplicationRunner runner(KafkaTemplate<Object, Object> template) {          return args -> {              template.send(MessageBuilder.withPayload(42)                      .setHeader(KafkaHeaders.TOPIC, "blog")                      .build());              template.send(MessageBuilder.withPayload("43")                      .setHeader(KafkaHeaders.TOPIC, "blog")                      .build());              Thread.sleep(5_000);          };      }        @Bean      public StringJsonMessageConverter converter() {          return new StringJsonMessageConverter();      }        @Component      @KafkaListener(id = "multi", topics = "blog")      public static class Listener {            @KafkaHandler          public void intListener(Integer in) {              System.out.println("Got an int: " + in);          }            @KafkaHandler          public void stringListener(String in) {              System.out.println("Got a string: " + in);          }        }    }

Got an int: 42  Got a string: 43