腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
圈层
工具
MCP广场
文章/答案/技术大牛
搜索
搜索
关闭
发布
搜索
关闭
文章
问答
(17)
视频
开发者手册
清单
用户
专栏
沙龙
全部问答
原创问答
Stack Exchange问答
更多筛选
回答情况:
全部
有回答
回答已采纳
提问时间:
不限
一周内
一月内
三月内
一年内
问题标签:
未找到与 相关的标签
筛选
重置
1
回答
kafka发到elasticSearch的数据在哪里?知道我在使用ElasticSearch接收器吗?
我认为一切都很好:[2018-07-06 22:27:51,471] INFO [Consumer clientId=
consumer
浏览 0
修改于2018-07-11
得票数 1
1
回答
当我为一个长期运行的处理添加一个新的使用者时,我如何正确地暂停/恢复考虑到发生的再平衡?
Message [message-3]
consumer
-4 Started
consumer-4
[partition-5 offsetpartition-7 offset-43] Committed [message-3] consumer-3 [par
浏览 9
修改于2020-08-12
得票数 0
1
回答
卡夫卡消费者信息提交问题
:13.140 INFO 1 --- [ad | bbb-bl-kyc] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=
consumer
:14.692 INFO 1 --- [container-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=
consumer
:15.151 INFO 1 --- [container-0-C-1] o.a.k.c.c.internals.Abstract
浏览 3
修改于2020-05-30
得票数 0
1
回答
spark streaming中批量时间与提交时间相差50分钟
dashboard] (Re-)joining group19/07/22 11:30:00 INFO internals.AbstractCoordinator: [Consumer clientId=
consumer
id: 2147483534 rack: null) 19/07/
浏览 62
修改于2019-07-23
得票数 0
回答已采纳
1
回答
如何处理镜像制造者2中的源主题删除?
[2022-05-12 14:42:57,473] WARN [Consumer clientId=
consumer-4
, groupId=null] Received unknown topic or
浏览 3
提问于2022-05-15
得票数 0
1
回答
如何使流从卡夫卡主题到elasticsearch与汇合?
来自汇合日志连接的错误: [2019-04-24 11:01:29,327] INFO [Consumer clientId=
consumer
org.apache.kafka.clients.consumer.internals.
浏览 0
修改于2019-04-24
得票数 1
回答已采纳
1
回答
Spring @StreamListener消费者未在消费者组中注册使用者ID、主机和客户端ID
15 0 consumer-4-bec1e4af-d771-47fe-83ad-3440f3a6d4bd /192.168.0.26
consumer
15 0 consumer-4-bec1e4af-d771-47fe-83ad-3440f3a6d4bd /192.168.0.26
consumer
浏览 3
修改于2019-09-05
得票数 0
回答已采纳
1
回答
Kafka描述了显示不礼貌的组命令
- consumer-4-090258c4-4d76-4cdd-8b62-f8fccf3ec097 /127.0.0.1
consumer
- consumer-4-090258c4-4d76-4cdd-8b62-f8fccf3ec097 /127.0.0.1
consumer
浏览 2
提问于2017-03-05
得票数 0
回答已采纳
1
回答
卡夫卡连接器弹性搜索不消耗话题
但大多数时候,它只是停留在和重复这个部分[2020-09-15 20:24:29,560] INFO [Consumer clientId=
consumer
org.apache.kafka.clients.consu
浏览 3
修改于2020-09-16
得票数 0
2
回答
春季靴卡夫卡消费滞后和阅读错误
2365090 11 consumer-4-0c9a5616-3e96-413b-b770-b813c3d38a28 /10.244.3.47
consumer
2365091 11 consumer-4-0c9a5616-3e96-413b-b770-b813c3d38a28 /10.244.3.47
consumer
2365245 15 consumer-4-0c9a5616-3e96-413b-b7
浏览 2
修改于2019-11-01
得票数 2
回答已采纳
1
回答
春天卡夫卡总是在5分钟后再平衡,即使我暂停了消费者。
org.springframework.kafka.KafkaListenerEndpointContainer#6-3-C-1] INFO o.a.k.c.c.i.AbstractCoordinator - [Consumer clientId=
consumer
org.springframework.kafka.KafkaListenerEndpointContainer#6-3-C-1] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=
consumer
org.springframew
浏览 0
修改于2018-11-14
得票数 5
回答已采纳
1
回答
卡夫卡断开后的消费者重新连接
58.023 INFO 18245 --- [ntainer#3-0-C-1] o.a.kafka.clients.FetchSessionHandler : [Consumer clientId=
consumer
浏览 0
修改于2020-06-20
得票数 12
回答已采纳
1
回答
自动提交偏移量失败&重试也不例外。
xxxxx-component-workflow-starter,,,] 11 --- [nt_create-2-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=
consumer
浏览 4
提问于2019-10-30
得票数 0
回答已采纳
1
回答
Spring消费者与2.3.13版本之间的不兼容性
02.700 INFO 2748 --- [ntainer#0-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=
consumer
02.700 INFO 2748 --- [ntainer#0-3-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=
consumer
02.700 INFO 2748 --- [ntainer#0-3-C-1] o.a.k.c.c.internals.Ab
浏览 8
修改于2022-05-17
得票数 0
1
回答
同样群体下的卡夫卡消费者在重新平衡后使用相同的分区。
Setting newly assigned partitions [topic.1-1, topic.1-0] 03/30/2022 10:23:47.484 [Consumer clientId=
consumer
浏览 9
修改于2022-04-26
得票数 1
1
回答
Apache光束: Kafka消费者一次又一次重启
AKrCWqWfQKOfb9OSgwFyIQ2019-06-07 16:08:31,649 INFO o.a.k.c.consumer.internals.Fetcher - [Consumer clientId=
consumer
AKrCWqWfQKOfb9OSgwFyIQ 2019-06-07 16:08:31,672 INFO
浏览 12
提问于2019-06-07
得票数 1
回答已采纳
1
回答
无法建立与节点-1的连接。
Broker may not be available. 2018-04-10 02:56:41,925|- [Consumer clientId=
consumer-4
, groupId=engine-kafka-consumer
浏览 0
提问于2018-04-10
得票数 4
领券