search

IBM / sarama

Sarama is a Go library for Apache Kafka.
MIT License
11.6k stars 1.76k forks source link

Sarama consumer group Owner #979

Closed liaojianqi closed 7 years ago

liaojianqi commented 7 years ago
Version

Sarama Version: 1.13.0 (2017-10-04) Kafka Version: kafka_2.11-0.10.1.0 Go Version: 1.9.2 darwin/amd64

Configuration
Logs
Problem Description

how to set consumer group's owner name? when I exec: ./kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group g1 then output: GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG OWNER g1 integration 0 319587936 352119221 32531285 none OWNER is 'none'.

I want to know hot to set consumer group's OWNER in sarama please?

eapache commented 7 years ago

https://github.com/Shopify/sarama/wiki/Frequently-Asked-Questions#how-can-i-use-sarama-to-monitor-or-join-a-consumer-group