SpringBoot为Kafka提供了两种配置方式
SpringBoot提供了KafkaProperties配置类，且会将spring.
KafkaProperties
spring.
我有一个kafka集群，有三个代理和一个主题，复制因子为三个分区和三个分区。我可以看到，每个代理都有相同大小的所有分区的日志副本。这个主题有两位制作人。 有一天，我把一个制片人的写作量减少了一半。然后我发现所有三个代理的入站流量都减少了，这是意料之中的，但只有分区1的领导节点的出站流量减少了，我不明白。 由于复制，分区主管的出站流量减少。但是每个代理都是一个分区的领导者，为什么只有一个领导者的出站
一、生产者发送消息的过程 首先介绍一下 Kafka 生产者发送消息的过程： Kafka 会将发送消息包装为 ProducerRecord 对象， ProducerRecord 对象包含了目标主题和要发送的内容，同时还可以指定键和分区。在发送 ProducerRecord 对象前，生产者会先把键和值对象序列化成字节数组，这样它们才能够在网络上传输。 接下来，数据被传给分区器。如果之前已经在 Prod
Kafka文件说，幂等生产者是可能的，与相同的生产者会话，我无法理解这一点。 比方说，Kafka为每条消息添加序列号，最后一个序列号在Kafka中维护（不确定它维护在哪里）。 它是如何生成序列号的，它保存在哪里？ 为什么当制作人崩溃并再次出现时，它不能保持序列？ 我怎样才能使它在制作人会话之间真正幂等？
Kafka为每条消息生成偏移量。假设，我正在生成消息5，偏移量将从1到5。 但是，在事务生产者中，比如说，我产生了5条消息并提交，然后是5条消息但中止，然后是5条消息提交。 > 那么，最后提交的5条消息的偏移量是6到10还是11到15？ 如果我不放弃或不promise呢。这些信息还会被发布吗？ Kafka是如何忽略未promise的补偿的？因此，kafka提交日志是基于偏移量的。它是否使用事务使用
这是我的密码。
我正在使用Kafka生产者发布消息到一些其他Kafka的主题，它的工作相当好。下面的示例模板： 上述语句是否支持kafka消息驱动入站通道适配器中所支持的errorchannel？ 每当我传出的kafka服务器宕机，我无法发布它时，我需要它来审计错误计数。
我没有使用Spring Kafka模块来生成和使用消息。相反，我在生产者和消费者实现中使用Apache客户端库。由于我没有使用Spring Kafka，因此Spring Slueth自动配置不适用于生成跟踪。我已经提到https://docs.spring.io/spring-cloud-sleuth/docs/current-SNAPSHOT/reference/html/integration
我目前正在开发Kafka模块，我正在使用Kafka通信的抽象。我能够集成生产者 Spring Boot测试类 监听器类 我的问题是：在测试类中，我断言分区、有效负载等是从BlockingQueue轮询的，然而，我的问题是如何验证用KafkaListener注释的类中的业务逻辑是否得到正确执行，并根据错误处理和其他业务场景将消息路由到不同的主题。在一些示例中，我看到了CountDownLatch的断
