在kafka中，多个消费者监听同个topic，此时一个消息过来，那么应该有以下两种情况可选：
1、多对一消费：所有消费者都能消费这个消息
2、一对一消费：只有一个消费者可以能消费到这条消息
请问kafka可以实现一对一消费吗？
如果可以，请提供实现的代码或链接给我，谢谢。
3条回答 默认 最新
- 2022-01-10 15:46回答 3 已采纳 消费者和生产者与机器无关，这是不同的概念，消费者与生产者只是在Kafka中的角色，不同角色干不同的事情
- 2022-10-25 09:26回答 5 已采纳 感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
- 2022-06-07 15:30回答 2 已采纳 想要实现这个问题需要如下几步：1、确定输入的志愿者数据的格式，比如：{"name":"志愿者1","age":28}2、SpringBoot集成Kafka，创建消费者服务3、获取Kafka中的数据，进
- 2023-07-14 08:53激流丶的博客 Kafka 消费者是使用 Apache Kafka 消息队列系统的应用程序，它们用于从 Kafka 主题（topics）中读取消息。消费者订阅一个或多个主题，并从这些主题中拉取消息以进行处理。消费者可以以不同的方式配置，例如，可以...
- 2021-07-02 11:07回答 2 已采纳 对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。对消费者来说， 你只需要消费下一条就行了。至于偏移量， 你第一次消费的时候，是要发送偏移的，这个你消费者要本地
- 2022-08-23 10:01回答 1 已采纳 同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
- 2022-02-16 19:32回答 4 已采纳 重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
- 2022-06-10 15:57Java天下第1的博客 点对点（point to point)发布/订阅（publish/subscribe）编辑消费者配置（确保同个名称group.id一样）创建topic, 1个分区 ./kafka-topics.sh --create --zookeeper IP:PORT --replication-factor 1 --partitions 2 -...
- 2022-06-11 10:41回答 1 已采纳 给你个例子，是可以收发的。验证通过再和你的对比一下，你应该哪里配错了。 springboot集成kafka、消息发送、消费使用_‘’小磊的博客-CSDN博客_spri
- 2022-01-28 09:47回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
- 2019-07-04 17:49回答 1 已采纳 This example shows a fully working console application which can consume for all partitions in a t
- 2023-02-07 16:35小叶同学的皮卡丘的博客 Java实现Kafka消费者及消息异步回调方式
- 2022-12-21 00:45回答 1 已采纳 这篇博客也许可以解决你的问题👉 ：kafka消费者从kafka读取信息
- 2023-04-23 17:34只不过是躺平的咸鱼的博客 1、下载安装zk，kafka...（大把教程，不在这里过多阐述）8、测试类分别测试单条消费以及批量消费。7、消费者配置类（配置批量消费）5、生产者发消息的工具类。
- 2022-09-29 11:42小叶同学的皮卡丘的博客 java实现Kafka指定offset位置进行消费及历史数据重复消费
- 没有解决我的问题, 去提问
悬赏问题
- ¥15 TI的insta-spin例程
- ¥15 完成下列问题完成下列问题
- ¥15 C#算法问题, 不知道怎么处理这个数据的转换
- ¥15 YoloV5 第三方库的版本对照问题
- ¥15 请完成下列相关问题！
- ¥15 drone 推送镜像时候 purge: true 推送完毕后没有删除对应的镜像,手动拷贝到服务器执行结果正确在样才能让指令自动执行成功删除对应镜像，如何解决？
- ¥15 求daily translation（DT）偏差订正方法的代码
- ¥15 js调用html页面需要隐藏某个按钮
- ¥15 ads仿真结果在圆图上是怎么读数的
- ¥20 Cotex M3的调试和程序执行方式是什么样的？