腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
3
回答
kafka
中的Bootstrap server vs zookeeper?
、
为什么不推荐使用
kafka
-consumer中的zookeeper,为什么建议使用bootstrap服务器?bootstrap-server有什么优点?
浏览 0
提问于2017-09-12
得票数 36
回答已采纳
2
回答
阅读由debezium postgres连接填充的Docker
Kafka
消息
、
、
、
55=
消费
者-1,群55=控制台-
消费
者-5221连接到节点-1 (
kafka
/23.202.231.166:9092)。(org.apache.
kafka
.clients.NetworkClient) 2019-06-03 21:55:16,289警告
消费
者客户55=
消费
者-1,群55=控制台-
消费
者-5221连接到节点(org.apache.
kafka
.clients.NetworkClient) 2019-06-03 21:55:16,
浏览 2
提问于2019-06-04
得票数 0
1
回答
Spring
Kafka
producer默认保证发货吗?
、
我想知道spring boot内部的spring
kafka
Producer是否保证交付。 有人知道如果某个随机监听器无法接收消息会发生什么情况吗?spring
kafka
是否会重试发送消息?
浏览 0
提问于2019-05-29
得票数 0
1
回答
如何使用Apache Nifi在多个节点上运行
Kafka
消费
者处理器实例
、
目前我们使用Apache NiFi通过
Kafka
consumer
消费
消息。
kafka
客户端的输出连接到hive处理器。 我正在研究如何在nifi集群上运行
kafka
消费
者实例。我有3个节点的nifi集群和一个有3个分区的
kafka
主题,我希望
kafka
消费
者能够在每个节点上运行,这样每个
消费
者可以从一个主题分区轮询消息。在我启动
kafka
消费
者处理器之后,我只能看到
kafka
<e
浏览 3
提问于2019-08-04
得票数 0
2
回答
Kafka
stream vs
kafka
消费
者如何决定使用什么
、
、
我做过一些
Kafka
流应用程序和
Kafka
消费
者应用程序。归根结底,
Kafka
流只是
消费
者,它
消费
来自
Kafka
的实时事件。所以我不知道什么时候使用
Kafka
streams,或者为什么我们应该使用
Kafka
streams,因为我们可以在
消费
者端执行所有的转换。我想了解
Kafka
stream和
Kafka
consumer之间的主要区别,以及如何在不同的用例中决定应该使用什么。
浏览 4
提问于2019-12-04
得票数 4
1
回答
如何测试
Kafka
的输出?
、
、
我正在尝试集成Flume和
Kafka
,其中Flume获取数据文件并推送到
Kafka
,然后推送到Spark。channels.channel1.transactionCapacity = 1000 如何测
浏览 1
提问于2015-10-31
得票数 1
2
回答
Spring Boot
Kafka
Consumer未
消费
,
Kafka
Listener未触发
、
、
、
我正在尝试构建一个简单的spring boot
Kafka
Consumer来
消费
来自
kafka
主题的消息,但是没有消息被
消费
,因为KafkaListener方法没有被触发。: 'application' compile "org.springframework.
kafka
; import org.springframework.
kafka</em
浏览 517
提问于2020-01-07
得票数 1
1
回答
如何知道卡夫卡队列中消耗了多少数据,卡夫卡队列中存在哪些数据?
、
、
、
、
我正在"topicDemo“
Kafka
中生成数据和
消费
数据,以启用分布式数据并并行处理这些数据。props.put("value.serializer", "org.apache.
kafka
.common.serialization.ByteArraySerializer");org.apache.
kafka
.clients.producer.Producer<Integer, byte[]> producer = new KafkaProducer<In
浏览 0
提问于2016-10-26
得票数 0
0
回答
kafka
生产者流量过大,导致consumer停止
消费
?
、
、
将tidb cdc流量打到
kafka
中,本地起consumer
消费
,但是每当生产者流量突然增大时,
消费
程序就停止
消费
,拉取不到topic数据,也不报错。springboot+
kafka
+批处理+自动提交offset@KafkaListener(topicPartitions =
浏览 327
提问于2022-02-08
2
回答
在Java中手动提交
Kafka
偏移量
、
、
我有一种情况(不要问),我有需要从外部服务提交给
Kafka
的偏移量信息(主题、分区、偏移量)。因为我不会从这个服务中进行任何
消费
,所以这似乎有点过头了。
浏览 0
提问于2018-10-31
得票数 2
1
回答
卡夫卡
消费
者中groupid与consumer - in的区别
、
我注意到Consumer配置有两个ID。一个是group.id (强制),另一个是consumer.id (非强制)。
浏览 2
提问于2016-01-01
得票数 45
1
回答
卡夫卡经纪人有没有可能失去
消费
者群体的抵销?
、
、
、
我在一个
Kafka
集群中
消费
一个
Kafka
主题(保留21天),作为
消费
者(最早/从开始)连续15天与x
消费
者组在一起,在第15天,生产者团队停止生产,我在我这边停止
消费
者,以确保没有剩余的消息可供
消费
然后
Kafka
集群也被关闭了。然后,在第16天,
Kafka
Cluster启动了,Producer在第23天启动了他的producer,我也启动了我自己的
消费
者。但当我开始的时候,我从一开始就收到了信息,而不是
浏览 29
提问于2020-07-24
得票数 0
2
回答
Logstash 5.1.1
kafka
输入不能提取主题中的现有消息
、
、
、
我有以下带有
kafka
输入的logstash配置
kafka
{ topics => ["
浏览 5
提问于2017-02-04
得票数 2
2
回答
为一个
kafka
主题创建多个
消费
者
、
我希望实现一个从
Kafka
主题
消费
的函数,对于每个
消费
的消息,它调用另一个方法对消息进行一些处理,然后将其存储在数据库中。源
kafka
主题有12个分区。我想在同一个
消费
群体下创建6到12个
kafka
消费
者。所有的
消费
者都将
消费
来自
Kafka
的消息并调用该函数。我不能得到一个好的设计。有人能帮帮我吗?
浏览 1
提问于2020-02-19
得票数 1
1
回答
kafka
消息监控,显示实际发布或
消费
的消息
、
我在本地服务器上安装了
kafka
,通过在服务器上运行的一些其他应用程序,生产人员正在将消息发布到我的
kafka
服务器内的代理,通过zookeeper,我可以很容易地看到我的
kafka
的健康状况,它显示了在我的
kafka
服务器中创建的所有主题,主题中的偏移量等等,所以zookeeper唯一不能显示的是单个主题中的消息,所以有人推荐
kafka
-manager工具,我安装并运行它,它工作得很好,它显示了来自我的
kafka
但它仍然不能显示由我的
kafka
服务器中的各个
消
浏览 7
提问于2016-08-19
得票数 0
1
回答
Kafka
nodejs单线程模型-添加
消费
者
、
、
我已经开发了一个基于Java的
Kafka
消费
者,其中每个
消费
者实例都有100个线程,当
消费
进程开始时,每个线程都会得到一个分区(因为有100个分区),
消费
就完成了。我计划切换到nodejs,并使用
kafka
-node作为客户端库,我正在
消费
该主题,如下所述:var HighLevelConsumer=
kafka
.HighLe
浏览 5
提问于2015-08-22
得票数 1
1
回答
在附加新主题的
消费
者之前,我在apache
kafka
中创建新主题并生成消息
、
在附加新主题的
消费
者之前,我创建新主题并在apache
kafka
中生成第一条消息。然后附加新主题的
消费
者,但无法
消费
第一条消息。为什么..?“提交的offset=1”不就意味着它已经被
消费
了吗?我的问题是,为什么它已经被
消费
了。如果有什么不对劲的地方,请告诉我。$
kafka
/bin/
kafka
-topics.sh --create --zookeeper localho
浏览 0
提问于2018-07-05
得票数 0
3
回答
C++中的卡夫卡
消费
者
、
、
我一直在搜索C++
kafka
consumer。我遇到了下面这些是C++
kafka
的,但没有
消费
者。(仅限示例生成器) 有没有人有基于上述工作的C++
kafka
消费
者或C++
kafka
消费
者的任何新方式
浏览 1
提问于2014-07-22
得票数 5
回答已采纳
2
回答
如何从
kafka
消息总线推送通知
消费
者
、
、
我正在使用C# asp.net Core2.0,
Kafka
,CQRS和Confluent
Kafka
.net库编写微服务应用程序。只是想知道
kafka
是否可以通知
消费
者,而不是
消费
者投票/
消费
消息? 谢谢
浏览 0
提问于2018-09-11
得票数 0
1
回答
Kafka
消费
者诉Apache Flink
、
、
、
、
我做了一个poc,在其中我使用火花流读取来自
Kafka
的数据。但是我们的组织要么使用Apache或者
Kafka
使用者来读取Apache中的数据作为一个标准过程。所以我需要用
Kafka
消费
者或者Apache来代替
Kafka
流媒体。在我的应用程序用例中,我需要从
kafka
读取数据,过滤json数据,并在cassandra中放置字段,因此建议使用
Kafka
使用者,而不是flink/其他流,因为我实际上不需要对
Kafka
json数据进行任何处理因此
浏览 4
提问于2017-03-26
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafka消费者API
kafka消费者分组消费的再平衡策略
使用多线程增加kafka消费能力
Kafka 的数据丢失和重复消费
Kafka之文件消费者应用案例
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券