Page History

...

• Purge repartition data on commit: this is summarized in 

  Jira
  server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key KAFKA-6150

  . The AdminClient's deleteRecords API (adding in KIP-204) will be used upon committing intervals.
• Create internal topic within InternalTopicManager: we will use the create topic API to do thatof AdminClient.
• We'll also remove the endless-loop checking after the creation within StreamPartitionAssignor (

  Jira
  server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key KAFKA-6126

  ); instead after the rebalance we will let the restoration retry within the main loop if the metadata is not known yet.
• Compatibility check: we will use a network client for this purpose, as it is a one-time thing.

...