腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(767)
视频
沙龙
1
回答
Kafka
rest
api
获取
消费
群体
详情
apache-kafka
、
confluent-platform
、
kafka-rest
我正在寻找一个
kafka
rest
api
,将列出相同的细节
kafka
-consumer-groups.sh --描述 将返回,基本上我正在尝试
获取
特定
消费
者组的每个分区的偏移量及其滞后的详细信息。
浏览 13
提问于2019-05-27
得票数 1
1
回答
生产者和
消费
者是否需要指定分区
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
我们计划让生产者(Java
rest
api
)和
消费
者(Java客户端)在多台机器上运行,并且所有
消费
者属于同一
消费
者组。1)在这种情况下,如果我在生产者发布
Kafka
写入随机/默认分区的消息时没有指定分区... 2)当
消费
者检索消息时,如果我没有提到分区,我会传递主题名称..and提交偏移量给
Kafka
服务器。如果我只有一个
消费
群体
,这是一个好方法吗?3)我是否需要
Kafka
r
浏览 11
提问于2016-02-24
得票数 2
1
回答
如何在合流
kafka
rest
代理中访问主题的最新偏移量来计算滞后
apache-kafka
、
kafka-rest
在合流的
kafka
rest
代理中,我们可以得到特定
消费
群体
的最后提交偏移量,但是如何才能得到主题的最新偏移量来计算滞后值。
浏览 2
提问于2019-07-11
得票数 0
1
回答
汇合CLI命令以
获取
偏移量和使用者组详细信息
apache-kafka
、
confluent-platform
、
confluent-cloud
嗨,我正在寻找一个汇合cli命令来使用GetOffsetShell来
获取
最早和最新的偏移量,并获得
消费
者组的详细信息。查找以下
kafka
命令,的汇合cli命令/opt/
kafka
/bin/
kafka
-run-class.sh
kafka
.tools.GetOffsetShell \ --topic my_topic \ --t
浏览 9
提问于2022-05-05
得票数 0
1
回答
获取
Kafka
用法的详细信息
apache-kafka
、
monitoring
、
kafka-consumer-api
、
kafka-producer-api
我希望收集以下资料: 我可以得到1和2使用动物园管理员的公用设施,但我是迷失在休息。我还尝试使用基于regex的表达式来
获取
这些mbean,但这也不起作用。 我使用的是<
浏览 1
提问于2019-02-12
得票数 0
1
回答
在
Kafka
中通过HTTP轮询
消费
者组滞后
apache-kafka
、
kafka-consumer-api
我想从
Kafka
看到针对特定
消费
者
群体
的接近实时的剩余延迟。我做过的最接近的事情就是从
Kafka
二进制文件中运行describe脚本,但是它很慢而且不可靠。我的第一个想法是在
消费
者中
获取
指标,并通过statsD发布到新的relic或datadog,然后通过HTTP进行轮询。这是我会长期做的事情。有没有一种更短期、更简单的方法来调查特定
群体
的
消费
滞后?
浏览 14
提问于2020-06-04
得票数 1
1
回答
Kafka
消费
群元数据
apache-kafka
、
kafka-consumer-api
卡夫卡版本2.4.1动物园管理员3.4.10参考:
消费
者组信息存储在哪里?(我尝试了zkcli.sh命令,/consumers是空的)哪里存储与使用者相关的信息&它的状态还有其他命令可以用来查询组信息(或任何黑客),
消费
者组成员存储在哪里?
浏览 0
提问于2020-05-01
得票数 1
回答已采纳
2
回答
如何使用direct stream在
Kafka
Spark Streaming中指定
消费
群
java
、
apache-spark
、
apache-kafka
、
spark-streaming
、
kafka-consumer-api
如何使用直播流
API
指定
kafka
spark流的
消费
组id。
浏览 0
提问于2016-04-09
得票数 7
回答已采纳
1
回答
如何使用KafkaAdminClient (Java)为2.x版本
获取
卡夫卡主题的最新偏移量/大小
java
、
apache-kafka
是否有更有效/更简单的方法来使用最新的Java客户端2.4
API
获取
主题/分区的大小/最新偏移量?然后,通过将
消费
者组的偏移量与主题的大小进行比较,计算
消费
者
群体
的滞后.我知道以前的
Kafka
版本也问过这个问题,也有一种方法可以从
Kafka
公开的JMX度量中
获取
这些信息,但是我仍然被一个遗留应用程序困住了,它需要用Java来完成,但我需要使用最新的2.4
Kafka
语言据我所知,
获取
这些
浏览 2
提问于2020-02-05
得票数 3
回答已采纳
1
回答
从
Kafka
拉取消息到两个目的地
apache-kafka
、
kafka-consumer-api
我能够
获取
kafka
消息并将其插入hdfs。我希望能够使用BI工具拉取相同的消息集。敬请指教。 谢谢
浏览 2
提问于2015-07-29
得票数 0
2
回答
为一个
kafka
主题创建多个
消费
者
java
、
apache-kafka
我希望实现一个从
Kafka
主题
消费
的函数,对于每个
消费
的消息,它调用另一个方法对消息进行一些处理,然后将其存储在数据库中。源
kafka
主题有12个分区。我想在同一个
消费
群体
下创建6到12个
kafka
消费
者。所有的
消费
者都将
消费
来自
Kafka
的消息并调用该函数。我不能得到一个好的设计。有人能帮帮我吗?
浏览 1
提问于2020-02-19
得票数 1
1
回答
informatica与
Kafka
的集成
apache-kafka
、
kafka-consumer-api
、
informatica
我计划在Informatica中使用
Kafka
数据对象。我想每5分钟通过Informatica从
Kafka
读取数据。我很少有疑问,卡夫卡如何认识到当前的偏移,从它必须加载。我们可以设置一个主题的偏移量,Informatica需要从它加载
Kafka
数据对象中的增量或更改的数据吗?请给我一个如何从卡夫卡
获取
数据的方法。斯利纳特
浏览 2
提问于2017-06-30
得票数 0
3
回答
一个
kafka
topic可以处理多少个
消费
群体
?
apache-kafka
、
kafka-consumer-api
、
kafka-topic
假设我有一个
kafka
主题,假设有大约10个分区,我理解每个
消费
者组在任何给定时间都应该有10个
消费
者阅读该主题,以实现最大的并行度。然而,我想知道在任何给定的时间点,对于一个主题可以处理的
消费
者
群体
的数量,是否有任何直接的规则。(在最近的一次采访中,我被问到了这个问题)。然而,只是想知道在给定的时间点上可以扩展多少个最大的
消费
者组(每个有10个
消费
者)?
浏览 0
提问于2019-07-09
得票数 7
1
回答
当所有
消费
者都被移除时,卡夫卡
消费
者
群体
会发生什么?
spring
、
spring-boot
、
apache-kafka
、
kafka-consumer-api
、
spring-kafka
我想知道如果所有的
消费
者都消失了,
消费
者
群体
会发生什么变化。我在汇合平台上注意到,我有许多
消费
者
群体
没有任何
消费
者。 没有任何
消费
者的
消费
者
群体
能存在多久?
浏览 5
提问于2020-10-22
得票数 7
回答已采纳
2
回答
如何使用Apache进行内容过滤?
java
、
apache-kafka
有一个生产者和两个
消费
者为这一主题。我需要做的是过滤由生产者产生的消息,根据它们的前缀。例如,如果消息以'a‘前缀开头,那么只有第一个使用者必须接受它。如果它以'b‘前缀开头,那么只有第二个
消费
者必须接受它。 我做了很多搜索,我发现的是过滤来自一个主题的消息,然后在过滤后将它们发送到不同的主题。但如前所述,我需要对一个主题进行过滤。
浏览 1
提问于2018-03-01
得票数 4
回答已采纳
2
回答
Kafka
推送的流程消息
rest
、
apache-kafka
、
kafka-consumer-api
我以前没有使用过
Kafka
,我想知道如果消息是通过
Kafka
发布的,有哪些可能的方法来捕获这些信息?我不需要发布信息,只需要处理从
Kafka
publisher收到的数据。任何提示都会有所帮助。
浏览 3
提问于2020-02-22
得票数 0
4
回答
如何从
kafka
服务器
获取
主题中的所有消息
apache-kafka
、
kafka-consumer-api
例如: 当使用上面的控制台命令时,我希望能够从一开始就
获取
主题中的所有消息,但是我无法使用
浏览 4
提问于2016-08-12
得票数 13
回答已采纳
1
回答
Apache的本地二进制TCP协议相对于restful有什么好处?
apache-kafka
根据Apache的文档,
Kafka
在其本地
API
的通信中使用了二进制TCP协议,但它们也为不支持Apache的本地
API
的语言提供了基于URL的restful。我只是想知道本地二进制TCP协议(在本机
API
中支持)是否比基于restful的与代理节点的通信有什么好处?我还在想restful是否还会维护only once属性呢?编辑: restful指南在这里:,它解释了如何在restful上生成和使用
Kafka
的消息
浏览 1
提问于2017-09-24
得票数 2
回答已采纳
1
回答
卡夫卡
Rest
代理
消费
者创造
apache-kafka
、
kafka-consumer-api
比方说,我有一个服务,它通过
kafka
-
rest
代理来
消费
消息,并且总是在同一个
消费
者
群体
上。我们还可以说,它正在消耗一个有一个分区的主题。当服务启动时,它在
kafka
-
rest
代理中创建一个新的使用者,并使用生成的使用者url直到服务被关闭。当服务恢复时,它将在
kafka
-
rest
代理中创建一个新的
消费
者,并使用新的url (和新的
消费
者)进行
消费
。 因为卡夫卡每个
浏览 1
提问于2016-07-07
得票数 2
回答已采纳
1
回答
如何从
消费
者
群体
的卡夫卡话题中找到
消费
数据的起始时间
java
、
apache-kafka
、
kafka-consumer-api
有什么
API
可以用来找出
消费
者
群体
从卡夫卡话题开始
消费
的起始时间吗? 我使用的是卡夫卡0.11版
浏览 3
提问于2017-12-07
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Apache Kafka 1.1.0 发布,改进 controller
Kafka详细的设计和生态系统
Kafka 1.0.1案例详解之Kafka Connect
中国民生银行大数据团队Kafka1.X管控实践
基于Kafka Connect的流数据同步服务实现和监控体系搭建
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券