kafka-console-consumer.sh --zookeeper y113:2181 --topic bro --security-protocol SASL_PLAINTEXT
Change configuration for a specific topic.
[root@y136 ~]# kafka-configs.sh \
--zookeeper $ZOOKEEPER \
--alter \
--entity-name pcap12 \
--entity-type topics \
--add-config max.message.bytes=100000000
[2017-05-11 15:46:18,515] ERROR
*****************************************************************************************************
*** WARNING: you are creating a topic where the max.message.bytes is greater than the broker's ***
*** default max.message.bytes. This operation is dangerous. There are two potential side effects: ***
*** - Consumers will get failures if their fetch.message.max.bytes (old consumer) or ***
*** max.partition.fetch.bytes (new consumer) < the value you are using ***
*** - Producer requests larger than replica.fetch.max.bytes will not replicate and hence have ***
*** a higher risk of data loss ***
*** You should ensure both of these settings are greater than the value set here before using ***
*** this topic. ***
*****************************************************************************************************
- value set here: 100000000
- Default Broker replica.fetch.max.bytes: 1048576
- Default Broker max.message.bytes: 1000012
- Default Old Consumer fetch.message.max.bytes: 1048576
- Default New Consumer max.partition.fetch.bytes: 1048576
(kafka.admin.TopicCommand$)
Are you sure you want to continue? [y/n]
y
Updated config for topic: "pcap12".
Show configuration for a specific topic.
[root@y136 ~]# kafka-configs.sh \
--zookeeper $ZOOKEEPER \
--describe \
--entity-name pcap12 \
--entity-type topics
Configs for topics:pcap12 are max.message.bytes=100000000