Versions Compared

Key

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

...

  • Support using --partitions options to specify a smaller number than current partitions
  • Add --deleteNow option delete-partitions-delay option (Long) to specify that when the data should be deleted right away. The default behavior is to delete after retention period passesvalue is 0 meaning the partition should be deleted right away.
Code Block
languagejava
linenumberstrue
./kafka-topics.sh --alter --topic ... --partitions ... --delete-partitions-immediateDeletePartitiondelay ...
  • The command will might issue warning when a topic contains keyed messageunder certain situations, such as
    • "WARNING: If partitions are increased for a topic that has a key, the partition logic or ordering of the messages will be affected"
    • "WARNING: This feature is only enabled with Metadata version above 10 and delete.topic.partition.enable turned on"
    • "WARNING: The topic is currently under changes"

Proposed Changes

We propose to add new status for a partition that indicates if a partition is to be removed. Specifically at any time a partition can be 

...