私はkafka 0.8.2を使用しています。ドキュメントにあるように、フェッチとコミットのオフセット API を使用したいです。
特定のコンシューマー グループのオフセットは、オフセット コーディネーターと呼ばれる特定のブローカーによって維持されます。つまり、コンシューマは、この特定のブローカにオフセット コミットおよびフェッチ リクエストを発行する必要があります。コンシューマー メタデータ リクエストを発行することで、現在のオフセット コーディネーターを検出できます。
したがってConsumerMetadataRequest、正しい応答を取得する代わりに、常にConsumerCoordinatorNotAvailableCodeを取得します。
ブローカーは、オフセット トピックがまだ作成されていない場合、コンシューマー メタデータ リクエストまたはオフセット コミット リクエストに対してこのエラー コードを返します。
問題のないkafka 0.8.2betaバージョンを使用すると。
また、go client sarama__consumer_offsetsを使用します。メタデータを取得する前にトピックを作成しました。そして、ここに私の設定があります：
broker.id=1
port=9091
host.name=192.168.33.10
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=102400
socket.receive.buffer.bytes=102400
socket.request.max.bytes=104857600
log.dirs=data/9091
num.partitions=1
num.recovery.threads.per.data.dir=1
log.retention.hours=168
log.segment.bytes=1073741824
log.retention.check.interval.ms=300000
log.cleaner.enable=false
zookeeper.connect=localhost:2181
zookeeper.connection.timeout.ms=6000