spring boot 1.5集成 kafka 消费者怎么自己确认消费 怎么使用@KafkaListener注解实现Acknowledgment，即消费者怎么自己提交游标
spring boot 1.5集成 kafka 消费者怎么自己确认消费
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
0条回答
- 2022-10-25 09:26回答 5 已采纳 感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
- 2022-08-23 10:01回答 1 已采纳 同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
- 2022-01-10 15:46回答 3 已采纳 消费者和生产者与机器无关，这是不同的概念，消费者与生产者只是在Kafka中的角色，不同角色干不同的事情
- 2021-05-08 12:32springboot-kafkastream Spring Boot 1.5和Kafka流示例
- 2022-12-21 00:45回答 1 已采纳 这篇博客也许可以解决你的问题👉 ：kafka消费者从kafka读取信息
- 2022-06-11 10:41回答 1 已采纳 给你个例子，是可以收发的。验证通过再和你的对比一下，你应该哪里配错了。 springboot集成kafka、消息发送、消费使用_‘’小磊的博客-CSDN博客_spri
- 2021-07-02 11:07回答 2 已采纳 对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。对消费者来说， 你只需要消费下一条就行了。至于偏移量， 你第一次消费的时候，是要发送偏移的，这个你消费者要本地
- 2023-04-02 14:25小白龙白龙马的博客 @KafkaListener(groupId = "testGroup", topicPartitions = { @TopicPartition(topic = "topic1", partitions = {"0", "1"}), @TopicPartition(topic = "topic2", partitions = "0", partitionOffsets = @Partiti...
- 2017-02-01 18:07回答 2 已采纳 The consumer group is specified by the second argument of the cluster consumer "constructor". Here
- 2021-07-05 16:53回答 1 已采纳 value的值为[B@1e1e585b这个明显是序列化后的Bytes字节类型嘛你反序列化成string就ok了
- 2016-10-25 09:13回答 4 已采纳 明白了，offset已经指到最后了，然后获取不到数据就一直等待状态，我以为卡死，生产者发送几个数据进去就行了
- 2023-03-26 18:24
- 2016-05-09 11:56回答 1 已采纳 你的这个结构首先要换一下。 如果你要去读取group中不同分区中的数据。对于你的consumer端来说，应该是1对1进行读取，也就是说，一个java进程对应一个分区partition。 你自己
- 2023-03-26 15:35小白龙白龙马的博客 ⼀个partition只能被⼀个消费组⾥的某⼀个消费者消费，从⽽保证消费顺序。 Kafka只在partition的范围内保证消息消费的局部顺序性，不能在同⼀个topic中的多个partition中保证总的消费顺序性。 ⼀个消费者可以消费多...
- 2023-03-25 19:37
- 没有解决我的问题, 去提问
