librdkafkaで複製係数を設定する方法は？

Question

私はlibrdkafkaを使ってC++ kafkaメッセージプロデューサーで開発しています。

カスタムレプリケーションファクタを使用してデフォルトのものとは異なるトピックを作成する方法はありますか？

CONFIGURATION.mdパラメータは明示的には言及されていませんが、カフカツールではこれが可能です。

Answer 1

自動トピック作成は現在librdkafkaでサポートされていますが、ブローカーのトピックのデフォルト設定を使用するだけです。

必要なのは、クライアントから手動でトピックを作成することです。ブローカーのサポートは最近KIP-4で行われましたが、現在librdkafka（またはJavaクライアント）ではサポートされていません。進行状況を追跡するにはIssue #986に従ってください。

今のところ、Kafkaに含まれているkafka-topics[.sh] --create ...スクリプトを使用することをお勧めします。