เจนเฉ เจนเจฌเจฐ!
เจฎเฉเจ เจเจฟเฉฐเจเฉเจซ เจเฉเจฎ 'เจคเฉ เจเฉฐเจฎ เจเจฐเจฆเจพ เจนเจพเจ, เจเฉ เจเจชเจฃเจพ เจธเฉเจเจจเจพ เจเฉเจเจฆเจฐ เจตเจฟเจเจธเจฟเจค เจเจฐ เจฐเจนเฉ เจนเฉเฅค เจฎเฉเจ เจเจผเจฟเจเจฆเจพเจคเจฐ เจธเจชเจฐเจฟเฉฐเจ เจฌเฉเจ เจฆเฉ เจตเจฐเจคเฉเจ เจเจฐเจเฉ เจเจพเจตเจพ เจตเจฟเฉฑเจ เจตเจฟเจเจธเจค เจเจฐเจฆเจพ เจนเจพเจ เจ เจคเฉ เจเฉฑเจ เจชเฉเจฐเฉเจเฉเจเจ เจตเจฟเฉฑเจ เจชเฉเจฆเจพ เจนเฉเจฃ เจตเจพเจฒเฉเจเจ เจเจ เจคเจเจจเฉเจเฉ เจธเจฎเฉฑเจธเจฟเจเจตเจพเจ เจจเฉเฉฐ เจนเฉฑเจฒ เจเจฐเจฆเจพ เจนเจพเจเฅค
เจธเจพเจกเฉเจเจ เจเจผเจฟเจเจฆเจพเจคเจฐ เจฎเจพเจเจเจฐเฉเจธเฉเจตเจพเจตเจพเจ เจเฉฑเจ เจธเฉฐเจฆเฉเจธเจผ เจฌเฉเจฐเฉเจเจฐ เจฐเจพเจนเฉเจ เจเฉฑเจ เจฆเฉเจเฉ เจจเจพเจฒ เจ เจธเจฟเฉฐเจเจฐเฉเจจเจธ เจคเฉเจฐ 'เจคเฉ เจธเฉฐเจเจพเจฐ เจเจฐเจฆเฉเจเจ เจนเจจเฅค เจชเจนเจฟเจฒเจพเจ, เจ เจธเฉเจ เจเฉฑเจ เจฌเฉเจฐเฉเจเจฐ เจตเจเฉเจ IBM MQ เจฆเฉ เจตเจฐเจคเฉเจ เจเฉเจคเฉ เจธเฉ, เจเฉ เจนเฉเจฃ เจฒเฉเจก เจฆเจพ เจธเจพเจนเจฎเจฃเจพ เจจเจนเฉเจ เจเจฐ เจธเจเจฆเจพ เจธเฉ, เจชเจฐ เจเจธเฉ เจธเจฎเฉเจ เจเฉฑเจ เจกเจฟเจฒเจฟเจตเจฐเฉ เจเจพเจฐเฉฐเจเฉ เจธเฉ.
เจเฉฑเจ เจฌเจฆเจฒ เจตเจเฉเจ, เจธเจพเจจเฉเฉฐ เจ เจชเจพเจเฉ เจเจพเจซเจเจพ เจฆเฉ เจชเฉเจธเจผเจเจธเจผ เจเฉเจคเฉ เจเจ เจธเฉ, เจเจฟเจธ เจตเจฟเฉฑเจ เจเฉฑเจ เจธเจเฉเจฒเจฟเฉฐเจ เจธเจฎเจฐเฉฑเจฅเจพ เจนเฉ, เจชเจฐ, เจฌเจฆเจเจฟเจธเจฎเจคเฉ เจจเจพเจฒ, เจตเฉฑเจ-เจตเฉฑเจ เจธเจฅเจฟเจคเฉเจเจ เจฒเจ เจธเฉฐเจฐเจเจจเจพ เจฒเจ เจฒเจเจญเจ เจตเจฟเจ เจเจคเฉเจเจค เจชเจนเฉเฉฐเจ เจฆเฉ เจฒเฉเฉ เจนเฉเฉฐเจฆเฉ เจนเฉเฅค เจเจธ เจคเฉเจ เจเจฒเจพเจตเจพ, เจเฉฑเจเฉ-เจเฉฑเจ เจเฉฑเจ เจตเจพเจฐ เจกเจฟเจฒเฉเจตเจฐเฉ เจตเจฟเจงเฉ เจเฉ เจกเจฟเจซเฉเจฒเจ เจฐเฉเจช เจตเจฟเฉฑเจ เจเจพเจซเจเจพ เจตเจฟเฉฑเจ เจเฉฐเจฎ เจเจฐเจฆเฉ เจนเฉ, เจจเฉ เจฌเจพเจเจธ เจคเฉเจ เจฌเจพเจนเจฐ เจเจเจธเจพเจฐเจคเจพ เจฆเฉ เจฒเฉเฉเฉเจเจฆเฉ เจชเฉฑเจงเจฐ เจจเฉเฉฐ เจฌเจฃเจพเจ เจฐเฉฑเจเจฃ เจฆเฉ เจเจเจพเจเจผเจค เจจเจนเฉเจ เจฆเจฟเฉฑเจคเฉเฅค เจ เฉฑเจเฉ, เจฎเฉเจ เจเจพเจซเจเจพ เจธเฉฐเจฐเจเจจเจพ เจตเจฟเฉฑเจ เจธเจพเจกเฉ เจ เจจเฉเจญเจต เจจเฉเฉฐ เจธเจพเจเจเจพ เจเจฐเจพเจเจเจพ, เจเจพเจธ เจคเฉเจฐ 'เจคเฉ, เจฎเฉเจ เจคเฉเจนเจพเจจเฉเฉฐ เจฆเฉฑเจธเจพเจเจเจพ เจเจฟ เจเจฟเจตเฉเจ เจธเฉฐเจฐเจเจฟเจค เจเจฐเจจเจพ เจนเฉ เจ เจคเฉ เจเฉฑเจ เจตเจพเจฐ เจกเจฟเจฒเฉเจตเจฐเฉ เจฆเฉ เจจเจพเจฒ เจเจฟเจตเฉเจ เจฐเจนเจฟเจฃเจพ เจนเฉเฅค
เจเจพเจฐเฉฐเจเฉเจธเจผเฉเจฆเจพ เจกเจฟเจฒเฉเจตเจฐเฉ เจ เจคเฉ เจนเฉเจฐ
เจนเฉเจ เจพเจ เจเจฐเจเจพ เจเฉเจคเฉ เจเจ เจธเฉเจเจฟเฉฐเจ เจกเจฟเจซเฉเจฒเจ เจเจจเฉเจเจธเจผเจจ เจธเฉเจเจฟเฉฐเจเจพเจ เจจเจพเจฒ เจเจ เจธเจฎเฉฑเจธเจฟเจเจตเจพเจ เจจเฉเฉฐ เจฐเฉเจเจฃ เจตเจฟเฉฑเจ เจฎเจฆเจฆ เจเจฐเฉเจเฉเฅค เจชเจฐ เจชเจนเจฟเจฒเจพเจ เจฎเฉเจ เจเฉฑเจ เจชเฉเจฐเจพเจฎเฉเจเจฐ เจตเฉฑเจฒ เจงเจฟเจเจจ เจฆเฉเจฃเจพ เจเจพเจนเจพเจเจเจพ เจเฉ เจเฉฑเจ เจธเฉฐเจญเจพเจตเฉ เจกเฉเจฌเฉฑเจ เจฆเฉ เจธเจนเฉเจฒเจค เจฆเฉเจตเฉเจเจพเฅค
เจเจน เจฎเจฆเจฆ เจเจฐเฉเจเจพ client.id เจเจคเจชเจพเจฆเจ เจ เจคเฉ เจเจชเจคเจเจพเจฐ เจฒเจ. เจชเจนเจฟเจฒเฉ เจจเจเจผเจฐ 'เจคเฉ, เจคเฉเจธเฉเจ เจเจชเจฒเฉเจเฉเจธเจผเจจ เจจเจพเจฎ เจจเฉเฉฐ เจฎเฉเฉฑเจฒ เจฆเฉ เจคเฉเจฐ 'เจคเฉ เจตเจฐเจค เจธเจเจฆเฉ เจนเฉ, เจ เจคเฉ เจเจผเจฟเจเจฆเจพเจคเจฐ เจฎเจพเจฎเจฒเจฟเจเจ เจตเจฟเฉฑเจ เจเจน เจเฉฐเจฎ เจเจฐเฉเจเจพเฅค เจนเจพเจฒเจพเจเจเจฟ เจธเจฅเจฟเจคเฉ เจเจฆเฉเจ เจเฉฑเจ เจเจชเจฒเฉเจเฉเจธเจผเจจ เจเจ เจเจชเจคเจเจพเจฐเจพเจ เจฆเฉ เจตเจฐเจคเฉเจ เจเจฐเจฆเฉ เจนเฉ เจ เจคเฉ เจคเฉเจธเฉเจ เจเจนเจจเจพเจ เจจเฉเฉฐ เจเจนเฉ client.id เจฆเจฟเฉฐเจฆเฉ เจนเฉ, เจจเจคเฉเจเฉ เจตเจเฉเจ เจนเฉเจ เจพเจ เจฆเจฟเฉฑเจคเฉ เจเฉเจคเจพเจตเจจเฉ เจนเฉเฉฐเจฆเฉ เจนเฉ:
org.apache.kafka.common.utils.AppInfoParser โ Error registering AppInfo mbean javax.management.InstanceAlreadyExistsException: kafka.consumer:type=app-info,id=kafka.test-0
เจเฉเจเจฐ เจคเฉเจธเฉเจ เจเจพเจซเจเจพ เจฆเฉ เจจเจพเจฒ เจเฉฑเจ เจเจชเจฒเฉเจเฉเจธเจผเจจ เจตเจฟเฉฑเจ JMX เจฆเฉ เจตเจฐเจคเฉเจ เจเจฐเจจเจพ เจเจพเจนเฉเฉฐเจฆเฉ เจนเฉ, เจคเจพเจ เจเจน เจเฉฑเจ เจธเจฎเฉฑเจธเจฟเจ เจนเฉ เจธเจเจฆเฉ เจนเฉเฅค เจเจธ เจเฉเจธ เจฒเจ, เจเจชเจฒเฉเจเฉเจธเจผเจจ เจจเจพเจฎ เจฆเฉ เจธเฉเจฎเฉเจฒ เจฆเฉ เจตเจฐเจคเฉเจ เจเจฐเจจเจพ เจธเจญ เจคเฉเจ เจตเจงเฉเจ เจนเฉ เจ เจคเฉ, เจเจฆเจพเจนเจฐเจจ เจฒเจ, client.id เจฎเฉเฉฑเจฒ เจฆเฉ เจฐเฉเจช เจตเจฟเฉฑเจ เจตเจฟเจธเจผเฉ เจฆเจพ เจจเจพเจฎเฅค เจธเจพเจกเฉ เจธเฉฐเจฐเจเจจเจพ เจฆเจพ เจจเจคเฉเจเจพ เจเจฎเจพเจเจก เจเจเจเจชเฉเฉฑเจ เจตเจฟเฉฑเจ เจฆเฉเจเจฟเจ เจเจพ เจธเจเจฆเจพ เจนเฉ เจเจพเจซเจเจพ-เจเจชเจคเจเจพเจฐ-เจธเจฎเฉเจน Confluent เจคเฉเจ เจเจชเจฏเฉเจเจคเจพเจตเจพเจ เจคเฉเจ:
เจเจ เจนเฉเจฃ เจเจพเจฐเฉฐเจเฉเจธเจผเฉเจฆเจพ เจธเฉฐเจฆเฉเจธเจผ เจกเจฟเจฒเฉเจตเจฐเฉ เจฒเจ เจฆเฉเจฐเจฟเจธเจผ เจจเฉเฉฐ เจตเฉเจเฉเจเฅค เจเจพเจซเจเจพ เจจเจฟเจฐเจฎเจพเจคเจพ เจฆเจพ เจเฉฑเจ เจชเฉเจฐเจพเจฎเฉเจเจฐ เจนเฉ acks, เจเฉ เจคเฉเจนเจพเจจเฉเฉฐ เจเจฒเฉฑเจธเจเจฐ เจฒเฉเจกเจฐ เจจเฉเฉฐ เจธเจซเจฒเจคเจพเจชเฉเจฐเจตเจ เจฒเจฟเจเฉ เจธเฉเจจเฉเจนเฉ 'เจคเฉ เจตเจฟเจเจพเจฐ เจเจฐเจจ เจฒเจ เจเจฟเฉฐเจจเฉ เจธเจตเฉเจเจพเจฐ เจเจฐเจจ เจคเฉเจ เจฌเจพเจ เจฆ เจธเฉฐเจฐเจเจฟเจค เจเจฐเจจ เจฆเฉ เจเจเจพเจเจผเจค เจฆเจฟเฉฐเจฆเจพ เจนเฉเฅค เจเจน เจชเฉเจฐเจพเจฎเฉเจเจฐ เจนเฉเจ เจฆเจฟเฉฑเจคเฉ เจฎเฉเฉฑเจฒ เจฒเฉ เจธเจเจฆเจพ เจนเฉ:
- 0 - เจฎเจพเจจเจคเจพ 'เจคเฉ เจตเจฟเจเจพเจฐ เจจเจนเฉเจ เจเฉเจคเจพ เจเจพเจตเฉเจเจพเฅค
- 1 เจกเจฟเจซเฉเจฒเจ เจชเฉเจฐเจพเจฎเฉเจเจฐ เจนเฉ, เจธเจฟเจฐเจซ 1 เจชเฉเจฐเจคเฉเจเฉเจฐเจฟเจคเฉ เจจเฉเฉฐ เจธเจตเฉเจเจพเจฐ เจเจฐเจจ เจฆเฉ เจฒเฉเฉ เจนเฉเฅค
- โ1 โ เจธเจพเจฐเฉเจเจ เจธเจฎเจเจพเจฒเฉ เจชเฉเจฐเจคเฉเจเฉเจฐเจฟเจคเฉเจเจ เจคเฉเจ เจธเจตเฉเจเจพเจฐ เจเจฐเจจเจพ เจเจผเจฐเฉเจฐเฉ เจนเฉ (เจเจฒเฉฑเจธเจเจฐ เจธเฉเฉฑเจเจ เฉฑเจช min.insync.replicas).
เจธเฉเจเฉเจฌเฉฑเจง เจฎเฉเฉฑเจฒเจพเจ เจคเฉเจ เจเจน เจธเจชเฉฑเจธเจผเจ เจนเฉ เจเจฟ โ1 เจฆเฉ เจฌเจฐเจพเจฌเจฐ acks เจธเจญ เจคเฉเจ เจฎเจเจผเจฌเฉเจค โโเจเจพเจฐเฉฐเจเฉ เจฆเจฟเฉฐเจฆเจพ เจนเฉ เจเจฟ เจธเฉเจจเฉเจนเจพ เจเฉเฉฐเจฎ เจจเจนเฉเจ เจนเฉเจตเฉเจเจพเฅค
เจเจฟเจตเฉเจ เจเจฟ เจ เจธเฉเจ เจธเจพเจฐเฉ เจเจพเจฃเจฆเฉ เจนเจพเจ, เจตเฉฐเจกเฉเจเจ เจชเฉเจฐเจฃเจพเจฒเฉเจเจ เจญเจฐเฉเจธเฉเจฏเฉเจ เจจเจนเฉเจ เจนเจจเฅค เจ เจธเจฅเจพเจ เจจเฉเจเจธ เจคเฉเจ เจฌเจเจพเจเจฃ เจฒเจ, เจเจพเจซเจเจพ เจจเจฟเจฐเจฎเจพเจคเจพ เจตเจฟเจเจฒเจช เจชเฉเจฐเจฆเจพเจจ เจเจฐเจฆเจพ เจนเฉ เจฆเฉเจฌเจพเจฐเจพ เจเฉเจธเจผเจฟเจธเจผ เจเจฐเจฆเจพ เจนเฉ, เจเฉ เจคเฉเจนเจพเจจเฉเฉฐ เจ เฉฐเจฆเจฐ เจฎเฉเฉ เจญเฉเจเจฃ เจฆเฉเจเจ เจเฉเจธเจผเจฟเจธเจผเจพเจ เจฆเฉ เจเจฟเจฃเจคเฉ เจจเฉเฉฐ เจธเฉเฉฑเจ เจเจฐเจจ เจฆเฉ เจเจเจพเจเจผเจค เจฆเจฟเฉฐเจฆเจพ เจนเฉ เจกเจฟเจฒเฉเจตเจฐเฉ.เจเจพเจเจฎเจเจเจ. เจเจฟเจเจเจเจฟ เจฆเฉเจฌเจพเจฐเจพ เจเฉเจธเจผเจฟเจธเจผเจพเจ เจฆเฉ เจชเฉเจฐเจพเจฎเฉเจเจฐ เจฆเจพ เจชเฉเจฐเจต-เจจเจฟเจฐเจงเจพเจฐเจค เจฎเฉเฉฑเจฒ Integer.MAX_VALUE (2147483647) เจนเฉ, เจธเฉเจจเฉเจนเฉ เจฆเฉเจเจ เจฎเฉเฉ เจเฉเจธเจผเจฟเจธเจผเจพเจ เจฆเฉ เจธเฉฐเจเจฟเจ เจจเฉเฉฐ เจธเจฟเจฐเจซเจผ delivery.timeout.ms เจจเฉเฉฐ เจฌเจฆเจฒ เจเฉ เจเจกเจเจธเจ เจเฉเจคเจพ เจเจพ เจธเจเจฆเจพ เจนเฉเฅค
เจ เจธเฉเจ เจฌเจฟเจฒเจเฉเจฒ เจเฉฑเจ เจตเจพเจฐ เจกเจฟเจฒเฉเจตเจฐเฉ เจตเฉฑเจฒ เจตเจง เจฐเจนเฉ เจนเจพเจ
เจธเฉเจเฉเจฌเฉฑเจง เจธเฉเจเจฟเฉฐเจเจพเจ เจธเจพเจกเฉ เจจเจฟเจฐเจฎเจพเจคเจพ เจจเฉเฉฐ เจเฉฑเจ เจเจพเจฐเฉฐเจเฉ เจฆเฉ เจจเจพเจฒ เจธเฉเจจเฉเจนเฉ เจกเจฟเจฒเฉเจตเจฐ เจเจฐเจจ เจฆเฉ เจเจเจพเจเจผเจค เจฆเจฟเฉฐเจฆเฉเจเจ เจนเจจเฅค เจเจ เจนเฉเจฃ เจเจธ เจฌเจพเจฐเฉ เจเฉฑเจฒ เจเจฐเฉเจ เจเจฟ เจเจน เจเจฟเจตเฉเจ เจฏเจเฉเจจเฉ เจฌเจฃเจพเจเจ เจเจพเจตเฉ เจเจฟ เจเฉฑเจ เจธเฉฐเจฆเฉเจธเจผ เจฆเฉ เจเฉเจตเจฒ เจเฉฑเจ เจเจพเจชเฉ เจเจพเจซเจเจพ เจตเจฟเจธเจผเฉ 'เจคเฉ เจฒเจฟเจเฉ เจเจ เจนเฉ? เจธเจงเจพเจฐเจจ เจฎเจพเจฎเจฒเฉ เจตเจฟเฉฑเจ, เจ เจเจฟเจนเจพ เจเจฐเจจ เจฒเจ, เจคเฉเจนเจพเจจเฉเฉฐ เจชเฉเจฐเฉเจกเจฟเจเจธเจฐ 'เจคเฉ เจชเฉเจฐเจพเจฎเฉเจเจฐ เจธเฉเฉฑเจ เจเจฐเจจ เจฆเฉ เจฒเฉเฉ เจนเฉ enable.idempotence เจธเฉฑเจ เจจเฉเฉฐ. เจเจกเจฎเจชเฉเจเฉเจเจธเฉ เจเจพเจฐเฉฐเจเฉ เจฆเจฟเฉฐเจฆเฉ เจนเฉ เจเจฟ เจเฉฑเจ เจตเจฟเจธเจผเฉ เจฆเฉ เจเฉฑเจ เจเจพเจธ เจญเจพเจ เจจเฉเฉฐ เจธเจฟเจฐเจซเจผ เจเฉฑเจ เจธเฉเจจเฉเจนเจพ เจฒเจฟเจเจฟเจ เจเจฟเจ เจนเฉเฅค เจเจฆเจฐเจธเจผเจคเจพ เจจเฉเฉฐ เจธเจฎเจฐเฉฑเจฅ เจฌเจฃเจพเจเจฃ เจฒเจ เจชเฉเจฐเจต เจธเจผเจฐเจค เจฎเฉเฉฑเจฒ เจนเจจ acks = เจธเจญ, เจฎเฉเฉ เจเฉเจธเจผเจฟเจธเจผ > 0, max.in.flight.requests.per.connection โค 5. เจเฉเจเจฐ เจเจน เจชเฉเจฐเจพเจฎเฉเจเจฐ เจกเจฟเจตเฉเจฒเจชเจฐ เจฆเฉเจเจฐเจพ เจจเจฟเจฐเจงเจพเจฐเจค เจจเจนเฉเจ เจเฉเจคเฉ เจเจ เจนเจจ, เจคเจพเจ เจเจชเจฐเฉเจเจค เจฎเฉเฉฑเจฒ เจเจชเจฃเฉ เจเจช เจธเฉเฉฑเจ เจนเฉ เจเจพเจฃเจเฉเฅค
เจเจฆเฉเจ idempotency เจธเฉฐเจฐเจเจจเจพ เจเฉเจคเฉ เจเจพเจเจฆเฉ เจนเฉ, เจคเจพเจ เจเจน เจฏเจเฉเจจเฉ เจฌเจฃเจพเจเจฃเจพ เจเจผเจฐเฉเจฐเฉ เจนเฉเฉฐเจฆเจพ เจนเฉ เจเจฟ เจเจนเฉ เจธเฉฐเจฆเฉเจธเจผ เจนเจฐ เจตเจพเจฐ เจเฉฑเจเฉ เจญเจพเจเจพเจ เจตเจฟเฉฑเจ เจเจคเจฎ เจนเฉเจฃเฅค เจเจน partitioner.class เจเฉเฉฐเจเฉ เจ
เจคเฉ เจชเฉเจฐเจพเจฎเฉเจเจฐ เจจเฉเฉฐ เจชเฉเจฐเฉเจกเจฟเจเจธเจฐ 'เจคเฉ เจธเฉเฉฑเจ เจเจฐเจเฉ เจเฉเจคเจพ เจเจพ เจธเจเจฆเจพ เจนเฉเฅค เจเจ เจเฉเฉฐเจเฉ เจจเจพเจฒ เจธเจผเฉเจฐเฉ เจเจฐเฉเจ. เจเจน เจนเจฐเฉเจ เจธเจฌเจฎเจฟเจธเจผเจจ เจฒเจ เจเฉฑเจเฉ เจเจฟเจนเจพ เจนเฉเจฃเจพ เจเจพเจนเฉเจฆเจพ เจนเฉเฅค เจเจน เจ
เจธเจฒ เจชเฉเจธเจ เจคเฉเจ เจเจฟเจธเฉ เจตเฉ เจเจพเจฐเฉเจฌเจพเจฐเฉ เจเจเจกเฉ เจฆเฉ เจตเจฐเจคเฉเจ เจเจฐเจเฉ เจเจธเจพเจจเฉ เจจเจพเจฒ เจชเฉเจฐเจพเจชเจค เจเฉเจคเจพ เจเจพ เจธเจเจฆเจพ เจนเฉเฅค partitioner.class เจชเฉเจฐเจพเจฎเฉเจเจฐ เจฆเจพ เจเฉฑเจ เจฎเฉเจฒ เจฎเฉเฉฑเจฒ เจนเฉ -
- เจเฉเจเจฐ เจธเฉเจจเฉเจนเจพ เจญเฉเจเจฃ เจตเฉเจฒเฉ เจญเจพเจ เจธเจชเจธเจผเจ เจคเฉเจฐ 'เจคเฉ เจฆเจฟเฉฑเจคเจพ เจเจฟเจ เจนเฉ, เจคเจพเจ เจ เจธเฉเจ เจเจธเจจเฉเฉฐ เจตเจฐเจคเจฆเฉ เจนเจพเจเฅค
- เจเฉเจเจฐ เจญเจพเจ เจจเจฟเจฐเจงเจพเจฐเจค เจจเจนเฉเจ เจเฉเจคเจพ เจเจฟเจ เจนเฉ, เจชเจฐ เจเฉเฉฐเจเฉ เจฆเจฟเฉฑเจคเฉ เจเจ เจนเฉ, เจคเจพเจ เจเฉเฉฐเจเฉ เจฆเฉ เจนเฉเจธเจผ เจฆเฉเจเจฐเจพ เจญเจพเจ เจเฉเจฃเฉเฅค
- เจเฉเจเจฐ เจญเจพเจ เจ เจคเฉ เจเฉเฉฐเจเฉ เจจเจฟเจฐเจงเจพเจฐเจค เจจเจนเฉเจ เจเฉเจคเฉ เจเจ เจนเฉ, เจคเจพเจ เจเฉฑเจ เจเฉฑเจ เจเจฐเจเฉ เจญเจพเจ เจเฉเจฃเฉ (เจฐเจพเจเจเจก-เจฐเฉเจฌเจฟเจจ)เฅค
เจจเจพเจฒ เจนเฉ, เจเฉฑเจ เจชเฉเจฐเจพเจฎเฉเจเจฐ เจฆเฉ เจจเจพเจฒ เจเฉฑเจ เจเฉเฉฐเจเฉ เจ เจคเฉ idempotent เจญเฉเจเจฃ เจฆเฉ เจตเจฐเจคเฉเจ เจเจฐเจฆเฉ เจนเฉเจ max.in.flight.requests.per.connection = 1 เจคเฉเจนเจพเจจเฉเฉฐ เจเจชเจญเฉเจเจคเจพ 'เจคเฉ เจธเฉเจเจพเจฐเฉ เจธเฉเจจเฉเจนเฉ เจฆเฉ เจชเฉเจฐเจเจฟเจฐเจฟเจ เจชเฉเจฐเจฆเจพเจจ เจเจฐเจฆเจพ เจนเฉเฅค เจเจน เจฏเจพเจฆ เจฐเฉฑเจเจฃ เจฏเฉเจ เจตเฉ เจนเฉ เจเจฟ เจเฉเจเจฐ เจคเฉเจนเจพเจกเฉ เจเจฒเฉฑเจธเจเจฐ 'เจคเฉ เจชเจนเฉเฉฐเจ เจจเจฟเจฏเฉฐเจคเจฐเจฃ เจจเฉเฉฐ เจเฉเจเจซเจฟเจเจฐ เจเฉเจคเจพ เจเจฟเจ เจนเฉ, เจคเจพเจ เจคเฉเจนเจพเจจเฉเฉฐ เจเจฟเจธเฉ เจตเจฟเจธเจผเฉ 'เจคเฉ เจตเจฟเจเจพเจฐเจธเจผเฉเจฒเจคเจพ เจจเจพเจฒ เจฒเจฟเจเจฃ เจฒเจ เจ เจงเจฟเจเจพเจฐเจพเจ เจฆเฉ เจเจผเจฐเฉเจฐเจค เจนเฉเจเจเฉเฅค
เจเฉเจเจฐ เจ เจเจพเจจเจ เจคเฉเจนเจพเจกเฉ เจเฉเจฒ เจเฉเฉฐเจเฉ เจฆเฉเจเจฐเจพ เจเจฎเจชเฉเจเฉเจเจ เจญเฉเจเจฃ เจฆเฉเจเจ เจธเจฎเจฐเฉฑเจฅเจพเจตเจพเจ เจฆเฉ เจเจพเจ เจนเฉ เจเจพเจ เจชเฉเจฐเฉเจกเจฟเจเจธเจฐ เจธเจพเจเจก 'เจคเฉ เจคเจฐเจ เจฒเจ เจตเฉฑเจ-เจตเฉฑเจ เจญเจพเจเจพเจ เจฆเฉ เจตเจฟเจเจเจพเจฐ เจกเจพเจเจพ เจเจเจธเจพเจฐเจคเจพ เจฌเจฃเจพเจ เจฐเฉฑเจเจฃ เจฆเฉ เจฒเฉเฉ เจนเฉ, เจคเจพเจ เจฒเฉเจฃ-เจฆเฉเจฃ เจฌเจเจพเจ เจฒเจ เจเจตเฉเจเจพเฅค เจเจธเจฆเฉ เจเจฒเจพเจตเจพ, เจเฉฑเจ เจเฉเจจ เจเฉเจฐเจพเจเจเฉเจเจธเจผเจจ เจฆเฉ เจตเจฐเจคเฉเจ เจเจฐเจฆเฉ เจนเฉเจ, เจคเฉเจธเฉเจ เจเจพเจซเจเจพ เจตเจฟเฉฑเจ เจเฉฑเจ เจฐเจฟเจเจพเจฐเจก เจจเฉเฉฐ เจธเจผเจฐเจค เจ เจจเฉเจธเจพเจฐ เจธเจฎเจเจพเจฒเฉ เจเจฐ เจธเจเจฆเฉ เจนเฉ, เจเจฆเจพเจนเจฐเจจ เจฒเจ, เจกเฉเจเจพเจฌเฉเจธ เจตเจฟเฉฑเจ เจเฉฑเจ เจฐเจฟเจเจพเจฐเจก เจฆเฉ เจจเจพเจฒ. เจจเจฟเจฐเจฎเจพเจคเจพ เจจเฉเฉฐ เจฒเฉเจฃ-เจฆเฉเจฃ เจญเฉเจเจฃ เจจเฉเฉฐ เจธเจฎเจฐเฉฑเจฅ เจฌเจฃเจพเจเจฃ เจฒเจ, เจเจน เจฒเจพเจเจผเจฎเฉ เจคเฉเจฐ 'เจคเฉ เจจเจฟเจฐเจชเฉฑเจ เจนเฉเจฃเจพ เจเจพเจนเฉเจฆเจพ เจนเฉ เจ เจคเฉ เจเจธ เจคเฉเจ เจเจฒเจพเจตเจพ เจธเฉเฉฑเจ เจเฉเจคเจพ เจเจพเจฃเจพ เจเจพเจนเฉเจฆเจพ เจนเฉ transactional.id. เจเฉเจเจฐ เจคเฉเจนเจพเจกเฉ เจเจพเจซเจเจพ เจเจฒเฉฑเจธเจเจฐ เจตเจฟเฉฑเจ เจเจเจธเฉเจธ เจเฉฐเจเจฐเฉเจฒ เจเฉเจเจซเจฟเจเจฐ เจเฉเจคเจพ เจเจฟเจ เจนเฉ, เจคเจพเจ เจเฉฑเจ เจเฉเจฐเจพเจเจเฉเจเจธเจผเจจเจฒ เจฐเจฟเจเจพเจฐเจก, เจเจฟเจตเฉเจ เจเจฟ เจเฉฑเจ idempotent เจฐเจฟเจเจพเจฐเจก, เจจเฉเฉฐ เจฒเจฟเจเจฃ เจฆเฉ เจเจเจพเจเจผเจค เจฆเฉ เจฒเฉเฉ เจนเฉเจตเฉเจเฉ, เจเฉ transactional.id เจตเจฟเฉฑเจ เจธเจเฉเจฐ เจเฉเจคเฉ เจฎเฉเฉฑเจฒ เจฆเฉ เจตเจฐเจคเฉเจ เจเจฐเจเฉ เจฎเจพเจธเจ เจฆเฉเจเจฐเจพ เจฆเจฟเฉฑเจคเฉ เจเจพ เจธเจเจฆเฉ เจนเฉเฅค
เจฐเจธเจฎเฉ เจคเฉเจฐ 'เจคเฉ, เจเฉเจ เจตเฉ เจธเจคเจฐ, เจเจฟเจตเฉเจ เจเจฟ เจเจชเจฒเฉเจเฉเจธเจผเจจ เจจเจพเจฎ, เจจเฉเฉฐ เจเฉเจฐเจพเจเจเฉเจเจธเจผเจจ เจชเจเจพเจฃเจเจฐเจคเจพ เจตเจเฉเจ เจตเจฐเจคเจฟเจ เจเจพ เจธเจเจฆเจพ เจนเฉเฅค เจชเจฐ เจเฉเจเจฐ เจคเฉเจธเฉเจ เจเฉฑเจเฉ เจเจชเจฒเฉเจเฉเจธเจผเจจ เจฆเฉเจเจ เจเจ เจเจฆเจพเจนเจฐเจจเจพเจ เจจเฉเฉฐ เจเจธเฉ transactional.id เจจเจพเจฒ เจฒเจพเจเจ เจเจฐเจฆเฉ เจนเฉ, เจคเจพเจ เจชเจนเจฟเจฒเฉ เจฒเจพเจเจ เจเฉเจคเฉ เจเจเจจเจพ เจจเฉเฉฐ เจเฉฑเจ เจเจฒเจคเฉ เจจเจพเจฒ เจฐเฉเจ เจฆเจฟเฉฑเจคเจพ เจเจพเจตเฉเจเจพ, เจเจฟเจเจเจเจฟ เจเจพเจซเจเจพ เจเจธเจจเฉเฉฐ เจเฉฑเจ เจเจผเฉเจเจฌเฉ เจชเฉเจฐเจเจฟเจฐเจฟเจ เจฎเฉฐเจจเฉเจเจพเฅค
org.apache.kafka.common.errors.ProducerFencedException: Producer attempted an operation with an old epoch. Either there is a newer producer with the same transactionalId, or the producer's transaction has been expired by the broker.
เจเจธ เจธเจฎเฉฑเจธเจฟเจ เจจเฉเฉฐ เจนเฉฑเจฒ เจเจฐเจจ เจฒเจ, เจ เจธเฉเจ เจนเฉเจธเจเจจเจพเจฎ เจฆเฉ เจฐเฉเจช เจตเจฟเฉฑเจ เจเจชเจฒเฉเจเฉเจธเจผเจจ เจจเจพเจฎ เจตเจฟเฉฑเจ เจเฉฑเจ เจชเจฟเจเฉเจคเจฐ เจเฉเฉเจฆเฉ เจนเจพเจ, เจเฉ เจ เจธเฉเจ เจตเจพเจคเจพเจตเจฐเจฃ เจตเฉเจฐเฉเจเจฌเจฒ เจคเฉเจ เจชเฉเจฐเจพเจชเจค เจเจฐเจฆเฉ เจนเจพเจเฅค
เจจเจฟเจฐเจฎเจพเจคเจพ เจจเฉเฉฐ เจเฉเจเจซเจฟเจเจฐ เจเฉเจคเจพ เจเจฟเจ เจนเฉ, เจชเจฐ เจเจพเจซเจเจพ 'เจคเฉ เจฒเฉเจฃ-เจฆเฉเจฃ เจธเจฟเจฐเจซ เจธเฉฐเจฆเฉเจธเจผ เจฆเฉ เจฆเจพเจเจฐเฉ เจจเฉเฉฐ เจจเจฟเจฏเฉฐเจคเจฐเจฟเจค เจเจฐเจฆเฉ เจนเจจเฅค เจฒเฉเจฃ-เจฆเฉเจฃ เจฆเฉ เจธเจฅเจฟเจคเฉ เจฆเฉ เจฌเจพเจตเจเฉเจฆ, เจธเฉเจจเฉเจนเจพ เจคเฉเจฐเฉฐเจค เจตเจฟเจธเจผเฉ 'เจคเฉ เจเจพเจเจฆเจพ เจนเฉ, เจชเจฐ เจเจธ เจตเจฟเฉฑเจ เจตเจพเจงเฉ เจธเจฟเจธเจเจฎ เจตเจฟเจธเจผเฉเจธเจผเจคเจพเจตเจพเจ เจนเจจเฅค
เจ
เจเจฟเจนเฉ เจธเฉฐเจฆเฉเจธเจผเจพเจ เจจเฉเฉฐ เจเจชเจญเฉเจเจคเจพ เจฆเฉเจเจฐเจพ เจธเจฎเฉเจ เจคเฉเจ เจชเจนเจฟเจฒเจพเจ เจชเฉเฉเจนเฉ เจเจพเจฃ เจคเฉเจ เจฐเฉเจเจฃ เจฒเจ, เจเจธ เจจเฉเฉฐ เจชเฉเจฐเจพเจฎเฉเจเจฐ เจธเฉเฉฑเจ เจเจฐเจจ เจฆเฉ เจฒเฉเฉ เจนเฉ isolation.level เจชเฉเฉเจนเจจ เจฒเจ_เจตเจเจจเจฌเฉฑเจง เจฎเฉเฉฑเจฒเฅค เจ
เจเจฟเจนเจพ เจเจชเจคเจเจพเจฐ เจชเจนเจฟเจฒเจพเจ เจฆเฉ เจคเจฐเฉเจนเจพเจ เจเฉเจฐ-เจฒเฉเจฃ-เจฆเฉเจฃ เจตเจพเจฒเฉ เจธเฉเจจเฉเจนเจฟเจเจ เจจเฉเฉฐ เจชเฉเฉเจน เจธเจเฉเจเจพ, เจ
เจคเฉ เจฒเฉเจฃ-เจฆเฉเจฃ เจตเจพเจฒเฉ เจธเฉเจจเฉเจนเจฟเจเจ เจจเฉเฉฐ เจเฉฑเจ เจตเจเจจเจฌเฉฑเจงเจคเจพ เจคเฉเจ เจฌเจพเจ
เจฆ เจนเฉ เจชเฉเฉเจน เจธเจเฉเจเจพเฅค
เจเฉเจเจฐ เจคเฉเจธเฉเจ เจชเจนเจฟเจฒเจพเจ เจธเฉเจเฉเจฌเฉฑเจง เจธเจพเจฐเฉเจเจ เจธเฉเจเจฟเฉฐเจเจพเจ เจธเฉเจ เจเจฐ เจฒเจเจเจ เจนเจจ, เจคเจพเจ เจคเฉเจธเฉเจ เจกเจฟเจฒเฉเจตเจฐเฉ เจคเฉเจ เจฌเจพเจ
เจฆ เจฌเจฟเจฒเจเฉเจฒ เจธเฉฐเจฐเจเจฟเจค เจเฉเจคเจพ เจนเฉเฅค เจตเจงเจพเจเจเจ!
เจชเจฐ เจเฉฑเจ เจนเฉเจฐ เจธเฉเจเจฎเจคเจพ เจนเฉ. Transactional.id, เจเจฟเจธเจจเฉเฉฐ เจ เจธเฉเจ เจเฉฑเจชเจฐ เจเฉเจเจซเจฟเจเจฐ เจเฉเจคเจพ เจนเฉ, เจ เจธเจฒ เจตเจฟเฉฑเจ เจเฉเจฐเจพเจเจเฉเจเจธเจผเจจ เจชเฉเจฐเฉเจซเจฟเจเจธ เจนเฉเฅค เจเฉเจฐเจพเจเจเฉเจเจธเจผเจจ เจฎเฉเจจเฉเจเจฐ 'เจคเฉ, เจเจธ เจตเจฟเฉฑเจ เจเฉฑเจ เจเฉเจฐเจฎ เจจเฉฐเจฌเจฐ เจเฉเฉเจฟเจ เจเจพเจเจฆเจพ เจนเฉเฅค เจชเฉเจฐเจพเจชเจค เจชเจเจพเจฃเจเจฐเจคเจพ เจจเฉเฉฐ เจเจพเจฐเฉ เจเฉเจคเจพ เจเจพเจเจฆเจพ เจนเฉ transactional.id.expiration.ms, เจเฉ เจเจพเจซเจเจพ เจเจฒเฉฑเจธเจเจฐ 'เจคเฉ เจเฉเจเจซเจฟเจเจฐ เจเฉเจคเจพ เจเจฟเจ เจนเฉ เจ เจคเฉ "7 เจฆเจฟเจจ" เจฆเจพ เจกเจฟเจซเฉเจฒเจ เจฎเฉเฉฑเจฒ เจนเฉเฅค เจเฉเจเจฐ เจเจธ เจธเจฎเฉเจ เจฆเฉเจฐเจพเจจ เจเจชเจฒเฉเจเฉเจธเจผเจจ เจจเฉเฉฐ เจเฉเจ เจธเฉฐเจฆเฉเจธเจผ เจชเฉเจฐเจพเจชเจค เจจเจนเฉเจ เจนเฉเจเจ เจนเฉ, เจคเจพเจ เจเจฆเฉเจ เจคเฉเจธเฉเจ เจ เจเจฒเฉ เจเฉเจฐเจพเจเจเฉเจเจธเจผเจจเจฒ เจญเฉเจเจฃ เจฆเฉ เจเฉเจธเจผเจฟเจธเจผ เจเจฐเฉเจเฉ เจคเจพเจ เจคเฉเจนเจพเจจเฉเฉฐ เจชเฉเจฐเจพเจชเจค เจนเฉเจตเฉเจเจพ InvalidPidMappingException. เจเฉเจฐเจพเจเจเฉเจเจธเจผเจจ เจเฉเจเจฐเจกเฉเจจเฉเจเจฐ เจซเจฟเจฐ เจ เจเจฒเฉ เจเฉเจฐเจพเจเจเฉเจเจธเจผเจจ เจฒเจ เจเฉฑเจ เจจเจตเจพเจ เจเฉเจฐเจฎ เจจเฉฐเจฌเจฐ เจเจพเจฐเฉ เจเจฐเฉเจเจพเฅค เจนเจพเจฒเจพเจเจเจฟ, เจเฉเจเจฐ InvalidPidMappingException เจจเฉเฉฐ เจธเจนเฉ เจขเฉฐเจ เจจเจพเจฒ เจจเจนเฉเจ เจธเฉฐเจญเจพเจฒเจฟเจ เจเจฟเจ เจคเจพเจ เจธเฉเจจเฉเจนเจพ เจเฉเฉฐเจฎ เจนเฉ เจธเจเจฆเจพ เจนเฉเฅค
เจเฉเจฒ เจฆเฉ เจฌเจเจพเจ
เจเจฟเจตเฉเจ เจเจฟ เจคเฉเจธเฉเจ เจฆเฉเจ เจธเจเจฆเฉ เจนเฉ, เจเจพเจซเจเจพ เจจเฉเฉฐ เจธเจฟเจฐเจซเจผ เจธเฉฐเจฆเฉเจธเจผ เจญเฉเจเจฃเจพ เจนเฉ เจเจพเจซเจผเฉ เจจเจนเฉเจ เจนเฉเฅค เจคเฉเจนเจพเจจเฉเฉฐ เจชเฉเจฐเจพเจฎเฉเจเจฐเจพเจ เจฆเฉ เจธเฉเจฎเฉเจฒ เจจเฉเฉฐ เจเฉเจฃเจจ เจฆเฉ เจฒเฉเฉ เจนเฉ เจ เจคเฉ เจคเฉเจฐเฉฐเจค เจคเจฌเจฆเฉเจฒเฉเจเจ เจเจฐเจจ เจฒเจ เจคเจฟเจเจฐ เจฐเจนเฉเฅค เจเจธ เจฒเฉเจ เจตเจฟเฉฑเจ, เจฎเฉเจ เจกเจฟเจฒเฉเจตเจฐเฉ เจธเฉเฉฑเจเจ เฉฑเจช เจจเฉเฉฐ เจฌเจฟเจฒเจเฉเจฒ เจเฉฑเจ เจตเจพเจฐ เจตเจฟเจธเจคเจพเจฐ เจตเจฟเฉฑเจ เจฆเจฟเจเจพเจเจฃ เจฆเฉ เจเฉเจธเจผเจฟเจธเจผ เจเฉเจคเฉ เจ เจคเฉ client.id เจ เจคเฉ transactional.id เจธเฉฐเจฐเจเจจเจพเจตเจพเจ เจฆเฉ เจจเจพเจฒ เจเจ เจธเจฎเฉฑเจธเจฟเจเจตเจพเจ เจฆเจพ เจตเจฐเจฃเจจ เจเฉเจคเจพ เจเจฟเจจเฉเจนเจพเจ เจฆเจพ เจ เจธเฉเจ เจธเจพเจนเจฎเจฃเจพ เจเฉเจคเจพเฅค เจนเฉเจ เจพเจ เจจเจฟเจฐเจฎเจพเจคเจพ เจ เจคเฉ เจเจชเจคเจเจพเจฐ เจธเฉเจเจฟเฉฐเจเจพเจ เจฆเจพ เจธเจพเจฐ เจนเฉเฅค
เจจเจฟเจฐเจฎเจพเจคเจพ:
- acks = เจธเจพเจฐเฉ
- เจฎเฉเฉ เจเฉเจธเจผเจฟเจธเจผเจพเจ > 0
- enable.idempotence = เจธเฉฑเจ
- max.in.flight.requests.per.connection โค 5 (เจเฉเจฐเจฎเจฌเฉฑเจง เจญเฉเจเจฃ เจฒเจ 1)
- transactional.id = ${application-name}-${hostname}
เจเจชเจคเจเจพเจฐ:
- isolation.level = read_committed
เจญเจตเจฟเฉฑเจ เจฆเฉเจเจ เจเจชเจฒเฉเจเฉเจธเจผเจจเจพเจ เจตเจฟเฉฑเจ เจเจฒเจคเฉเจเจ เจจเฉเฉฐ เจเฉฑเจ เจเจฐเจจ เจฒเจ, เจ เจธเฉเจ เจฌเจธเฉฐเจค เจธเฉฐเจฐเจเจจเจพ เจเฉฑเจคเฉ เจเจชเจฃเจพ เจฐเฉเจชเจฐ เจฌเจฃเจพเจเจ เจนเฉ, เจเจฟเฉฑเจฅเฉ เจธเฉเจเฉเจฌเฉฑเจง เจชเฉเจฐเจพเจฎเฉเจเจฐเจพเจ เจตเจฟเฉฑเจเฉเจ เจเฉเจ เจฒเจ เจฎเฉเฉฑเจฒ เจชเจนเจฟเจฒเจพเจ เจนเฉ เจธเฉเฉฑเจ เจเฉเจคเฉ เจเจ เจนเจจเฅค
เจเฉฑเจฅเฉ เจธเจตเฉ-เจ เจงเจฟเจเจจ เจฒเจ เจเฉเจ เจธเจฎเฉฑเจเจฐเฉเจเจ เจนเจจ:
KIP-98 - เจเฉฑเจ เจตเจพเจฐ เจกเจฟเจฒเจฟเจตเจฐเฉ เจ เจคเฉ เจเฉเจฐเจพเจเจเฉเจเจธเจผเจจเจฒ เจฎเฉเจธเฉเจเจฟเฉฐเจ เจธเฉเจเจฟเฉฐเจเจพเจ เจฆเจพ เจตเฉเจฐเจตเจพ
เจธเจฐเฉเจค: www.habr.com