Versions Compared

Old Version 6

changes.mady.by.user guozhang Wang

Saved on

compared with

New Version 7

changes.mady.by.user guozhang Wang

Saved on

Key

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

...

  • Purge repartition data on commit: this is summarized in 
    Jira
    serverASF JIRA
    serverId5aa69414-a9e9-3523-82ec-879b028fb15b
    keyKAFKA-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 that, and also we'll remove the endless-loop checking after the creation within StreamsPartitionAssignor, instead StreamPartitionAssignor; 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. 

...