7.9. トピック設定の変更

トピック設定の変更

1. kafka-configs.sh ツールを使用して、現在の設定を取得します。

   • --bootstrap-server オプションで Kafka ブローカーのホストおよびポートを指定します。
   • --entity-type を topic として、--entity-name をトピックの名前に設定します。

   • --describe オプション: 現在の設定を取得するために使用します。

     /opt/kafka/bin/kafka-configs.sh --bootstrap-server <broker_host>:<port> --entity-type topics --entity-name <topic_name> --describe

     Copy to Clipboard Toggle word wrap

     mytopic という名前のトピックの設定を取得するコマンドの例

     /opt/kafka/bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name mytopic --describe

     Copy to Clipboard Toggle word wrap

2. kafka-configs.sh ツールを使用して、現在の設定を変更します。

   • --bootstrap-server オプションで Kafka ブローカーのホストおよびポートを指定します。
   • --entity-type を topic として、--entity-name をトピックの名前に設定します。
   • --alter オプション: 現在の設定を変更するために使用します。

   • --add-config オプション: 追加または変更するオプションを指定します。

     /opt/kafka/bin/kafka-configs.sh --bootstrap-server <broker_host>:<port> --entity-type topics --entity-name <topic_name> --alter --add-config <option>=<value>

     Copy to Clipboard Toggle word wrap

     mytopic という名前のトピックの設定を変更するコマンドの例

     /opt/kafka/bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name mytopic --alter --add-config min.insync.replicas=1

     Copy to Clipboard Toggle word wrap

3. kafka-configs.sh ツールを使用して、既存の設定オプションを削除します。

   • --bootstrap-server オプションで Kafka ブローカーのホストおよびポートを指定します。
   • --entity-type を topic として、--entity-name をトピックの名前に設定します。
   • --delete-config オプション: 既存の設定オプションを削除するために使用します。

   • --remove-config オプション: 削除するオプションを指定します。

     /opt/kafka/bin/kafka-configs.sh --bootstrap-server <broker_host>:<port> --entity-type topics --entity-name <topic_name> --alter --delete-config <option>

     Copy to Clipboard Toggle word wrap

     mytopic という名前のトピックの設定を変更するコマンドの例

     /opt/kafka/bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name mytopic --alter --delete-config min.insync.replicas

     Copy to Clipboard Toggle word wrap