✎ @#*

改了之后：虽然钉钉还会在网络波动的时候报警，因为数据从生产到目标topic大概会用1分钟时间。但是再也没有重复消费情况了。感谢！

改了之后：虽然钉钉还会在网络波动的时候报警，因为数据从生产到目标topic大概会用1分钟时间。但是再也没有重复消费情况了。感谢！

啊，不知道理解的对不对？：
第一个代码是：病人是对象，注射类型、是否注射、病人都是其属性。显然这些东西作为病人的属性是不“面向对象的”。就比如我们不能说猫是狗的对象，只能说狗有个属性是玩，把对象猫给它，它就能玩了。
第二个代码是：病人是对象，他有个方法是注射疫苗，直接调方法就能实现功能。但是细节未知。
第三个代码是：病人、护士、疫苗都是不同对象，先选出疫苗类型，护士可以做的事是打标准疫苗，只要将疫苗和病人给护士，护士就能完成这个事情。

啊，不知道理解的对不对？：
第一个代码是：病人是对象，注射类型、是否注射、病人都是其属性。显然这些东西作为病人的属性是不“面向对象的”。就比如我们不能说猫是狗的对象，只能说狗有个属性是玩，把对象猫给它，它就能玩了。
第二个代码是：病人是对象，他有个方法是注射疫苗，直接调方法就能实现功能。但是细节未知。
第三个代码是：病人、护士、疫苗都是不同对象，先选出疫苗类型，护士可以做的事是打标准疫苗，只要将疫苗和病人给护士，护士就能完成这个事情。

收到，感谢大佬，我立马试试，
1、每次发送后提交
2、去除休眠
（当时休眠的原因是正式环境担心数据量太大，比较可能拉一次很多数据，但是发是一条一条的，担心kafka扛不住之类的原因）

timeout没了，消费了之后，又调用producer()这个方法，你用了线程池，还休眠3秒，我觉得是这段逻辑写的有问题，如果你把自动提交改成每条提交一次，至少不会在报错了，如：

records.forEach(
record -> {
    String data =
            convertDataService.convertData(record.value());
    logger.info("解析后数据 ： " + data);
    String topic = convertDataService.getTopic();
    logger.info("发送到topic： " + topic);
    producer(data, topic);

    consumer.commitAsync();   // 这里
});

唉，放弃了，加了依赖还是搞不定netty_tcnative问题：（conscrypt倒是搞定了）

<!-- https://mvnrepository.com/artifact/org.conscrypt/conscrypt-openjdk-uber -->
<dependency>
    <groupId>org.conscrypt</groupId>
    <artifactId>conscrypt-openjdk-uber</artifactId>
    <version>2.5.1</version>
    <scope>runtime</scope>
</dependency>
<!-- https://mvnrepository.com/artifact/io.netty/netty-all -->
<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>5.0.0.Alpha2</version>
</dependency>
<!-- https://mvnrepository.com/artifact/io.netty/netty-tcnative -->
<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-tcnative</artifactId>
    <version>2.0.0.Final</version>
</dependency>
<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-tcnative-boringssl-static</artifactId>
    <version>2.0.0.Final</version>
</dependency>