私はカフカが初めてです。1 つのトピックとそのトピックに割り当てられた 1 つのコンシューマー グループを使用して、単純なキュー システムを実装しようとしています。ただし、消費者グループを作成する方法がわかりませんでした。
ps kafka-rb gem で Ruby を使用しています。
ありがとう!エリック
私はカフカが初めてです。1 つのトピックとそのトピックに割り当てられた 1 つのコンシューマー グループを使用して、単純なキュー システムを実装しようとしています。ただし、消費者グループを作成する方法がわかりませんでした。
ps kafka-rb gem で Ruby を使用しています。
ありがとう!エリック
kafka コンシューマ ( http://kafka.apache.org/documentation.html )の構成を見ると、group.id
このコンシューマが属するコンシューマ グループを識別する一意の文字列です。
デフォルトでは、「」です。
それkafka-rb
を行う方法を提供していないようです。しかし、他の宝石は、https: //github.com/zendesk/ruby-kafka#consumer-groups https://github.com/karafka/karafka#groups
のようにそれを行うのに役立ち
ます