Versions Compared

Key

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

...

Each mirror maker thread has a consumer instance associate with it, the thread will be responsible for decompression, message handling and compression. All mirror maker thread threads share a producer.

The only source of truth for offsets is target cluster. The offsets should only be committed after having received the confirmation from the target cluster. For the new producer, the confirmation is the ACK from target cluster.

...