请教个问题，使用spring kafka 本地调试循环发送1W+消息时，就会会出现producer超时被强制关闭异常，但是部署到服务器循环发送10W+消息都不会出现这种异常，两者使用一样的producer 配置，能帮忙分析下是什么原因吗？
java.lang.IllegalStateException: Producer is closed forcefully.
at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:696) [kafka-clients-1.0.1.jar:na]
at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:683) [kafka-clients-1.0.1.jar:na]
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:185) [kafka-clients-1.0.1.jar:na]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_144]
程序不是优雅停机导致的吧。
还真是停机导致的，我加多个@kafkalistener，spring容器不会关闭，就不会出现producer被强制关闭这个问题了；
但是，我实现CommandLineRunner接口，在run方法内部循环发送，理论上也要执行完发送消息逻辑才会停机吧？，除非CommandLineRunner有时间限制？能帮忙解答下吗？？
代码如下：
@SpringBootApplication @EnableKafkaingBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, argsApplication @EnableKafkas KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplicationtApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static voidication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @AutowiredApplication @EnableKafkaafka public@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { publictApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void mainication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, argsApplication @EnableKafkas KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplicationtApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void mainication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @AutowiredApplication @EnableKafkaafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public staticication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.classApplication @EnableKafkaafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] argsotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExample; @Autowired private KafkaProducerUtil kafkaProducerUtil; @OverrideApplication @EnableKafkaafka public@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { publicotApplication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implementsingBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { publicotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] argsingBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExampleApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(Stringication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExample; @Autowired privateApplication @EnableKafkas KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplicationotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void mainication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExample; @Autowired private KafkaProducerUtilApplication @EnableKafkaafka public@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public staticotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(Stringication @EnableKafka public class KafkaExampleApplication implementsSpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args@SpringBootApplication @EnableKafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static voidication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired privateApplication @EnableKafkaafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplicationotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void mainication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired privateApplication @EnableKafkaafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(StringotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static voidication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] argsingBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExample; @Autowired@SpringBootApplication @EnableKafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] argsotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExampleApplication @EnableKafkaafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplicationotApplication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public staticication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, argsApplication @EnableKafkaafka public@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunnerotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void mainication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample@SpringBootApplication @EnableKafkas KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplicationotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(Stringication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExampleApplication @EnableKafkas KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @AutowiredApplication @EnableKafka public@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public staticotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] argsingBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExampleApplication @EnableKafkaafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplicationotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void mainication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { publicingBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExample; @Autowired private KafkaProducerUtil@SpringBootApplication @EnableKafka public@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public staticotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void mainication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExampleApplication @EnableKafkas KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static voidication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { publicingBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExample; @Autowired private KafkaProducerUtil kafkaProducerUtil; @Override public void run(String... args) { for@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] argsotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] argsication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample@SpringBootApplication @EnableKafkas KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplicationotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { publicingBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExampleApplication @EnableKafkaafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplicationotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExample; @AutowiredApplication @EnableKafkaafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static voidication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExample; @Autowired private KafkaProducerUtil kafkaProducerUtil; @Override public void run(String@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static voidication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExampleApplication @EnableKafkaafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static voidication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExample; @Autowired private KafkaProducerUtil kafkaProducerUtil; @Override public void run(String... args) { for (int i@SpringBootApplication @EnableKafka public@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public staticotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(Stringication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExampleSpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public staticotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main@SpringBootApplication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExampleApplication @EnableKafkaafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplicationotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void mainication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplicationSpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample@SpringBootApplication @EnableKafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public staticication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { publicingBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExample@SpringBootApplication @EnableKafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public staticication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implementsSpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { publicingBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunnerSpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExample; @Autowired private KafkaProducerUtil kafkaProducerUtil; @Override public@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired privateingBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.classApplication @EnableKafkas KafkaExampleApplication implements CommandLineRunner { public static void main(String@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implementsingBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication@SpringBootApplication @EnableKafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static voidication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExample; @Autowired private KafkaProducerUtil kafkaProducerUtil; @Override publicSpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void mainotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExample@SpringBootApplication @EnableKafkas KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplicationotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExampleApplication @EnableKafka publicafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplicationotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main@SpringBootApplication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample@SpringBootApplication @EnableKafkas KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExampleApplication @EnableKafkaafka publics KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static voidication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExampleApplication @EnableKafkaafka publicSpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public staticotApplication @EnableKafka@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public staticSpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample@SpringBootApplication @EnableKafka public@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public staticSpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static voidication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExampleingBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExample@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public staticotApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void@SpringBootApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunneringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication@SpringBootApplication @EnableKafka public class KafkaExampleApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(KafkaExampleApplication.class, args); } @Autowired private KafkaProducerExample kafkaProducerExample; @Autowired private KafkaProducerUtil kafkaProducerUtil; @Override public void run(String... args) { for (int i=0; i<50000; i++) { kafkaProducerExample.sendMsg(); } } }1、可以在main方法里，增加几秒的休眠。
2、在for方法会面追加
producer.close();可参考：https://www.orchome.com/303
你的答案