Kafka Consumer应用的问题

Kafka Consumer可以支持按Key消费信息么？不支持的话下面的场景可以通过一种什么思路实现呢？
应用场景：文件中转
detail：一个文件有不同的版本，均通过producer入broker，消费时取出特定版本的文件

写回答
好问题 0 提建议
追加酬金
关注问题
分享
邀请回答
编辑收藏删除结题
收藏举报

1条回答

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
dabocaiqq 2016-11-07 10:17
关注
http://blog.csdn.net/qqqq724/article/details/43228863/

解决无用
评论打赏
分享
举报

评论

按下Enter换行，Ctrl+Enter发表内容

报告相同问题？

关注问题

kafka拉取不到数据 java kafka 分布式有问必答
2022-02-16 19:32

回答 4 已采纳重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
Springboot集成kafka，应用很卡，消费很慢 java kafka spring boot
2022-10-25 09:26

回答 5 已采纳感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
kafka可以生产无法消费的问题 java kafka
2022-06-11 10:41

回答 1 已采纳给你个例子，是可以收发的。验证通过再和你的对比一下，你应该哪里配错了。 springboot集成kafka、消息发送、消费使用_‘’小磊的博客-CSDN博客_spri
Kafka consumer
2021-02-10 16:29

炒栗子不加糖的博客 Kafka consumer consumer概览消费者组消费者组定义：消费者使用一个消费者组名（即group.id）来标记自己，topic的每条消息都只会被发送到每个订阅它的消费者组的一个消费者实例上一个consumer group可能有若干个...
pycharm中kafka错误问题 kafka python ubuntu 有问必答
2021-06-17 17:19

回答 10 已采纳 https://blog.csdn.net/qq_40407889/article/details/118028472 java的kafka操作的简单demo
关于kafka Debezium捕获mysql问题 java kafka mysql
2022-10-26 12:40

回答 4 已采纳 MySQL binlog状态，连接器startup.model选项使用那种形式，最后不行在看debezium的日志
在win10启动kafka报错 kafka zookeeper
2022-05-15 21:27

回答 1 已采纳删除异常的主题“movie_real_topic”试试.\bin\kafka-topics --delete --topic movie_real_topic --zookeeper localhos
python kafkaconsumer poll_python操作kafka
2021-03-17 01:39

weixin_39628384的博客一、什么是kafkakafka特性：(1) 通过磁盘数据结构提供消息的持久化，这种结构对于即使数以TB的消息存储也能够保持长时间的稳定性能.(2) 高吞吐量：即使是非常普通的硬件Kafka也可以支持每秒数百万的消息.(3) 支持...
请问一下，如何启动Kafka加载consumer？数据库
2021-12-29 10:52

回答 1 已采纳可使用gbase> stop kafka consumer kafka_load_testdb_tt1;Query OK, 0 rows affected (Elapsed: 00:00:01.
K8S kafka集群外部访问的问题 kafka kubernetes 运维
2022-07-21 16:59

回答 1 已采纳内部是9092端口，外部用31082端口
KAFKA中生产者和分区的问题 kafka
2023-01-06 12:17

回答 1 已采纳是的。如果有副本的话，副本分区也有这个消息。
Kafka Consumer开发
2022-12-24 21:28

u013433591的博客 kafka拉取模式、精确一次、至少一次、最多一次语义、auto.offset.reset
Flume和kafka连接的问题 flume 大数据
2018-07-21 14:46

回答 1 已采纳 https://blog.csdn.net/weixin_40137479/article/details/79214312
KafkaConsumer Api
2022-04-14 15:52

lanicc的博客 KafkaConsumer 消费者组和Topic订阅 Groups and Topic Subscriptions Kafka uses the concept of consumer groups to allow a pool of processes to divide the work of consuming and processing records. These ...
【Kafka】KafkaConsumer消费者客户端实现原理
2021-10-27 19:48

sun_tantan的博客每个线程实例化一个KafkaConsumer对象2. 仅多线程处理消息一、消费者和消费组消费者：订阅kafka中的主题Topic，并且从订阅的主题上拉取消息。消费组：每个消费者都有一个对应的消费组，当消息发布到主题后，...
没有解决我的问题, 去提问

悬赏问题

¥15 js调用html页面需要隐藏某个按钮
¥15 ads仿真结果在圆图上是怎么读数的
¥20 Cotex M3的调试和程序执行方式是什么样的？
¥15 一道python难题3
¥15 牛顿斯科特系数表表示
¥15 arduino 步进电机
¥20 程序进入HardFault_Handler
¥15 oracle集群安装出bug
¥15 关于#python#的问题：自动化测试
¥20 问题请教！vue项目关于Nginx配置nonce安全策略的问题