Versions Compared

Key

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

...

    1. INIT_PRODUCER_ID for idempotent producer request PIDs from random controller every time so if a client got throttled on one controller doesn't guarantee it will not go through on next controller causing OOM at the leader later.
    2. The problem happened on the activation of the PID when it produce and not at the initialisation. Which means Kafka wouldn't have OOM problem if the producer got assigned PID but crashed before producing anything.
    3. Throttling producers that crash between initialisation and producer producing could slow them down when they recover/fix the problem that caused them to crash right after after initialising PID PID

5. Throttle PIDs based on IPs

...