Kafka获取订阅某topic的所有consumer group【客户端版】
之前写过如何用服务器端的API代码来获取订阅某topic的所有consumer group，参见这里。使用服务器端的API需要用到kafka.admin.AdminClient类，但是这个类在0.11.0.0版本已经被标记为不推荐使用了，故目前最合适的方式还是通过客户端API ...
原文：查询订阅某topic的所有consumer group(Java API)
在网上碰到的问题，想了下使用现有的API还是可以实现的。 首先，需要引入Kafka服务器端代码，比如加入Kafka . . 依赖： Maven lt dependency gt lt groupId gt org.apache.kafka lt groupId gt lt artifactId gt kafka . lt artifactId gt lt version gt . . lt ver ...
2017-11-14 11:48 3 1393 推荐指数：
相关推荐
Kafka Java consumer动态修改topic订阅
前段时间在Kafka QQ群中有人问及此事——关于Java consumer如何动态修改topic订阅的问题。仔细一想才发现这的确是个好问题，因为如果简单地在另一个线程中直接持有consumer实例然后调用subscribe进行修改，consumer端必然会抛出异常 ...
Kafka查看topic、consumer group状态命令
、replica信息 3，查看consumer group列表，使用--list参数 查看consumer gr ...
Kafka查看topic、consumer group状态命令
最近工作中遇到需要使用kafka的场景，测试消费程序启动后，要莫名的过几十秒乃至几分钟才能成功获取到到topic的partition和offset，而后开始消费数据，于是学习了一下查看kafka broker里topic和consumer group状态的相关命令，这里记录一下。 命令参考 ...
Kafka查看topic、consumer group状态命令
最近工作中遇到需要使用kafka的场景，测试消费程序启动后，要莫名的过几十秒乃至几分钟才能成功获取到到topic的partition和offset，而后开始消费数据，于是学习了一下查看kafka broker里topic和consumer group状态的相关命令，这里记录一下。 命令参考 ...
Java API获取consumer group最新提交位移的时间
碰到了有人问起这个问题，目前java consumer没有利用OffsetAndMetadata中的metadata字段记录提交的时间，故直接通过java consumer来查询是不行，我们需要直接读取__consumer_offsets，代码如下: public static long ...
java api如何获取kafka所有Topic列表,并放置为一个list
kafka内部所有的实现都是通过TopicCommand的main方法,通过java代码调用API，TopicCommand.main(options)的方式只能打印到控制台，不能转换到一个list。 下面讲解下如何转换为list： 1、查看主题（Topic） 【命令方式】：bin ...
Kafka Java API操作topic
Kafka官方提供了两个脚本来管理topic，包括topic的增删改查。其中kafka-topics.sh负责topic的创建与删除；kafka-configs.sh脚本负责topic的修改和查询，但很多用户都更加倾向于使用程序API的方式对topic进行操作 ...