我是Kafka的新人，我面临一个消费群的问题，我有一个logstash消费群，这是很久以前创建的，现在我创建了一个新的Kafka主题，从solr开始，它会自动添加到卡夫塔消费群“logstash”，如果我用其他名称创建任何其他主题，它不会添加到该消费群，所以我想知道如何才能找到为使用者组配置属性信息。我怀疑在创建时为这个用户组提供了配置。这是Kafka0.10
093gszye1#
这可能不是最好的方法。您可以简单地重新启动此使用者组中的任何使用者。kafka打印应用程序开始时使用的所有consumer config属性。如果我没记错的话，它会在信息级别打印所有日志。因此，请调整您的日志生成日志在信息级别或低于 INFO （可能吧） DEBUG 或者 TRACE )您将能够看到它使用的配置属性是什么。
INFO
DEBUG
TRACE
1条答案
按热度按时间093gszye1#
这可能不是最好的方法。
您可以简单地重新启动此使用者组中的任何使用者。kafka打印应用程序开始时使用的所有consumer config属性。如果我没记错的话，它会在信息级别打印所有日志。因此，请调整您的日志生成日志在信息级别或低于
INFO（可能吧）DEBUG或者TRACE)您将能够看到它使用的配置属性是什么。