Versions Compared

Old Version 5

changes.mady.by.user Ming-Yen Chung

Saved on

compared with

New Version 6

changes.mady.by.user Ming-Yen Chung

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • kafka-console-producer.sh
    • The option Using the --max-partition-memory-bytes option will display a warning:
      "Warning: --max-partition-memory-bytes is deprecated and will be marked as deprecated and then removed in the next major release.removed in a future version. Use --batch-size instead." 

Proposed Changes

  • Correct the inaccurate description of --batch-size to reflect that it controls byte size, not message count
  • Mark --max-partition-memory-bytes as deprecated, directing users to --batch-size instead.

  • To maintain backward compatibility, the existing behavior where --max-partition-memory-bytes overrides --batch-size will be preserved until the deprecated option is removed.

...

Code Block
 ./kafka-console-producer.sh
This tool helps to read data from standard input and publish it to Kafka.
Option                                   Description                            
------                                   -----------                            
--batch-size <Integer: size>             The buffer size in bytes allocated for a partition.
 										   When records are received 
                                           which are smaller than this size the 
                                           producer will attempt to             
                                           optimistically group them together   
                                           until this size is reached. This is  
                                           the option to control `batch.size`   
                                           in producer configs. (default: 16384)
             							   please note that this option will be 
										   replaced if max-partition-memory-bytes
										   is also set.

--max-partition-memory-bytes <Integer:   (Deprecated) The buffer size allocated for a partition.
  memory in bytes per partition>           When records are received
                                           which are smaller than this size the 
                                           producer will attempt to             
                                           optimistically group them together   
                                           until this size is reached. This is  
                                           the option to control `batch.size`   
                                           in producer configs. (default: 16384)
							         	   This option will be removed in a 
										   future version. Use --batch-size instead.

./kafka-console-producer.sh --topic test --bootstrap-server localhost:9092 --max-partition-memory-bytes 16384
Warning: --max-partition-memory-bytes is deprecated and will be removed in a future version. Use --batch-size instead.

...