問題タブ [librdkafka]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
c++ - librdkafka を使用する kafka プロデューサーの文字列ではなく入力としての構造
プロデューサーで文字列ではなく構造として入力を取得し、librdkafka ライブラリを使用してコンシューマーでそれを出力する必要があります。プロデューサー コードを変更し、構造を取得することさえできましたが、コンシューマーでは必要な場合に plz ヘルプが表示されません。より多くの変更
コード プロデューサーのコードは次のとおりです。
消費者コード:
ruby - Kafka エラー: 不明なパーティション (unknown_partition)
私はhttps://github.com/zendesk/racecarを使用しています(ボンネットの下でhttps://github.com/appsignal/rdkafka-rubyを使用しており、 https://github.com/edenhill/librdkafka/の Ruby ラッパーです)。 ) Kafka ストリームを消費すると、時々このエラーが発生しますLocal: Unknown partition (unknown_partition)
rd_kafka_offset_storeこのエラーは、 を呼び出したときに発生するようですstore offset of a message to be used in the next commit of this consumer。
上記のエラーのように見えるログをconfig.log_level = "debug"調べると、常に次のようになります。
ここで初めて Kafka を使用しましたが、何が何なのかわかりません。