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 of 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.
• We'll add an ADMIN_PREFIX (String contant valued "admin.") in the StreamsConfig for admin client usage which will allow certain config parameters for the admin client only, also add the adminClientPrefix function; this is similar to PRODUCER_PREFIX and CONSUMER_PREFIX.
• Compatibility check: we will remove this functionality and defer to the runtime to detect the returned error code and throw exception.

...