为Spring Boot Kafka项目配置Kafka使用者确认模式
我使用的是Spring Boot版本1.5.2。与SpringKafka版本1.1.2一起发布。释放通过应用程序。属性文件我确实看到了配置kafka使用者的可用选项（spring.kafka.consumer.*）。
但我找不到配置确认模式的方法。
共有2个答案
您可以使用SpringCloudStreamKafka绑定器来流式传输消息。那样的话
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream-binder-kafka</artifactId>
</dependency>
并像这样配置消费者。
spring.cloud.stream.kafka.bindings.<channelName>.consumer..
像这样的制片人
spring.cloud.stream.kafka.bindings.<channelName>.producer..
要了解更多详细信息，请观看本视频或本视频
SpringKafka。听众。确认模式=
-
我需要使用consume process Product模式来处理Kafka消息，并已使用Kafka事务管理器配置了Spring Kafka侦听器容器，还设置了事务id前缀以启用Kafka事务。我正在使用批处理的ack模式，并试图了解在这种模式下，在事务中何时提交偏移量。文档似乎表明，一旦使用了轮询中的所有记录，ack模式批提交偏移量——在事务上下文中也是这样吗，即每个轮询1个事务？ 或者，在使用
-
我们使用的是spring集成kafka版本3.1.2。RELEASE and int kafka：消息驱动的通道适配器，用于使用来自远程kafka主题的消息。生产者发送加密消息，我们使用反序列化器解密实际消息。我们可以使用主题中发布的所有消息。我们将自动提交用作false。我们想知道在成功处理消息后如何从我们的服务提交或确认消息。有人能帮助我们如何提交从消息驱动通道读取的消息并提供一些参考实现吗？
-
直接集成 GoJavaNode.jsPython 名称 描述 模型 策略 VMware Harbor VMware的开源可信云本地注册表项目，用于存储、签名和扫描内容。 Code Beego ORM Intel RMD 英特尔的资源管理守护进程。 .conf .csv VMware Dispatch 用于部署和管理无服务器风格应用程序的框架。 Code Code Skydive 一个开源的实时网络
-
/usr/local/kafka2.12-2.6.0/config/server.properties 在开始动物园管理员和Kafka之后，创建一个新的主题 检查所有三个节点上的集群状态
-
项目配置 项目配置 配置简介 CAT上项目名称：项目接入CAT后的唯一标识，来识别自己 事业部：项目所属事业部 产品线：项目所属产品线 负责人：项目负责人，该项不做为告警联系人 项目组邮件：项目负责人邮件，或项目组产品线邮件，多个邮箱由英文逗号分割，不要留有空格；作为发送告警邮件、微信的依据 项目组号码：项目负责人手机号；多个号码由英文逗号分隔，不要留有空格；作为发送告警短信的依据 机器分组配置
-
我很难理解如何解决这个问题，所以我在这里问这个问题，希望其他人已经面临同样的问题。我们正在以手动确认模式运行@KafkaListener，死信恢复程序的重试限制为3。由于业务逻辑，在特定情况下（外部依赖），我们不确认消息并暂停消费5分钟，因此需要手动确认模式。 此外，我们确实需要由于某种原因无法处理的消息的死信队列。 现在，在手动确认模式下的问题是，当侦听器/消费者达到重试限制并将其移动到dl队列