当前位置:  开发笔记 > 编程语言 > 正文

如何在Kafka的命令行中获取主题的group.id?

如何解决《如何在Kafka的命令行中获取主题的group.id?》经验,为你挑选了1个好方法。

我在服务器上安装了kafka,并想学习如何使用它,找到了scala编写的示例代码,下面是其中的一部分,

def createConsumerConfig(zookeeper: String, groupId: String): ConsumerConfig = {
    val props = new Properties()
    props.put("zookeeper.connect", zookeeper)
    props.put("group.id", groupId)
    props.put("auto.offset.reset", "largest")
    props.put("zookeeper.session.timeout.ms", "400")
    props.put("zookeeper.sync.time.ms", "200")
    props.put("auto.commit.interval.ms", "1000")
    val config = new ConsumerConfig(props)
    config
}

但我不知道如何在服务器上找到组ID。



1> Lundahl..:

group id是你自己定义为你的消费者通过东西为它提供一个字符串ID。以相同ID开头的所有使用者将以协作的方式“协作”并阅读主题,其中每个使用者实例将处理主题中消息的子集。提供不存在的组ID将被视为新使用者,并在Zookeeper中创建新条目,其中将存储已提交的偏移量。

推荐阅读
放ch养奶牛
这个屌丝很懒,什么也没留下!
DevBox开发工具箱 | 专业的在线开发工具网站    京公网安备 11010802040832号  |  京ICP备19059560号-6
Copyright © 1998 - 2020 DevBox.CN. All Rights Reserved devBox.cn 开发工具箱 版权所有