เบชเบทเบเบเปเปเบเบฒเบเปเบเบเบฒเบชเบฒเบเบญเบเบเบถเปเบกเบเปเบญเบ:
เบเบงเบฒเบกเปเบเบปเปเบฒเปเบเบเบฒเบเบซเบเปเบฒเบเปเปเบเบงเบฒเบก
author: Jakub Korab, เบเบนเปเบเบฑเบเบเบดเบก: O'Reilly Media, Inc., เบงเบฑเบเบเบตเบเบดเบกเปเบเบตเบเปเบเป: เปเบเบทเบญเบเบกเบดเบเบธเบเบฒ 2017, ISBN: 9781492049296.
เบเบฒเบเบชเปเบงเบเบเบตเปเปเบเบเปเบฒเบเบกเบฒ:
เบเบปเบเบเบต 3
Kafka
Kafka เปเบเปเบเบทเบเบเบฑเบเบเบฐเบเบฒเปเบเบ LinkedIn เปเบเบทเปเบญเปเบซเปเปเบเปเบเบฐเบกเบฒเบเบเบฒเบเบเปเปเบเปเบฒเบเบฑเบเบเบญเบเบเบฒเบเบซเบเปเบฒเบเปเปเบเบงเบฒเบกเปเบเบเบเบฑเปเบเปเบเบตเบกเปเบฅเบฐเบซเบผเบตเบเปเบงเบฑเปเบเบเบฒเบเบเบฑเปเบเบเบปเบงเบเบฒเบเบซเบเปเบฒเบเปเปเบเบงเบฒเบกเบซเบผเบฒเบเบชเปเบฒเบฅเบฑเบเบเบฒเบเปเบเปเบเบญเบเบเบธเบเบเปเปเบเบธเบเบเบตเปเปเบเบเบเปเบฒเบเบเบฑเบ, เปเบเบดเปเบเปเบเปเบญเบฐเบเบดเบเบฒเบเปเบงเปเปเบเบซเบเบฑเบเบชเบทเปเบซเบผเบฑเปเบกเบเบตเปเบเบฒเบเปเบเป "เบเบฒเบเบเบฐเบซเบเบฒเบเปเบฅเบฐเบญเบญเบ" เปเบเบซเบเปเบฒ 28 เบเปเบฅเบฐเบเบตเบเบฒเบเบเปเบฒเปเบเป LinkedIn เบชเปเบงเบเปเบซเบเปเปเบกเปเบเบญเบตเบเปเบชเปเบเบฒเบเบเปเบฒเปเบเบปเปเบฒเบเปเปเบกเบนเบเบซเบเบถเปเบเบเบฒเบเบเบฝเบงเบเบญเบเบเปเปเบกเบนเบเบเปเบฒเบเบงเบเบซเบผเบงเบเบซเบผเบฒเบเปเบเบฑเปเบเบเบฒเบเบเบฅเบดเบเบซเบเปเบฒเปเบฅเบฐเบเบฑเบเบเบถเบเบเบฒเบเปเบเบปเปเบฒเปเบเบดเบ, เปเบเบเบฐเบเบฐเบเบตเปเบเบฑเบเบญเบฐเบเบธเบเบฒเบเปเบซเปเบเปเปเบกเบนเบเบเบฑเปเบเบเบทเบเบเปเบฒเปเบเปเปเบเบเบซเบผเบฒเบเบฅเบฐเบเบปเบเปเบเบเบเปเปเบกเบตเบเบปเบเบเบฐเบเบปเบเบเปเปเบเบฒเบเบเบฐเบฅเบดเบเบเบญเบเบเบนเปเบเบฐเบฅเบดเบเบซเบผเบทเบเบนเปเบเปเบฅเบดเปเบเบเบญเบทเปเบเป. เปเบเบเบงเบฒเบกเปเบเบฑเบเบเบดเบ, เปเบซเบเบเบปเบเบเบตเป Kafka เบกเบตเบขเบนเปเปเบกเปเบเปเบเบทเปเบญเปเบซเปเปเบเปเบเบฐเปเบเบเบเบญเบเบชเบฐเบเบฒเบเบฑเบเบเบฐเบเบฐเบเปเบฒเบเปเปเบเบงเบฒเบกเบเบตเป Universal Data Pipeline เบญเบฐเบเบดเบเบฒเบ.
เปเบเบทเปเบญเบเบเบฒเบเปเบเบปเปเบฒเบซเบกเบฒเบเบชเบนเบเบชเบธเบเบเบตเป, เบเบงเบฒเบกเบเปเบญเบเบเบฒเบเบญเบทเปเบเปเบเปเปเปเบเบตเบเบเบทเปเบเบเบฒเบกเบเปเบฒเบกเบฐเบเบฒเบ. Kafka เบเบงเบ:
- เบเบฐเปเบงเบเบตเปเบชเบธเบ
- เปเบซเปเปเบเบเบงเบดเบเบซเบผเบฒเบเบเบถเปเบเปเบกเบทเปเบญเปเบฎเบฑเบเบงเบฝเบเบเบฑเบเบเปเปเบเบงเบฒเบก
- เบฎเบญเบเบฎเบฑเบ Publisher-Subscriber เปเบฅเบฐเบเบปเบงเปเบเบ Point-to-Point
- เบขเปเบฒเบเปเบฒเบฅเบปเบเบเปเบงเบเบเบฒเบเปเบเบตเปเบกเบเบนเปเบเปเบฅเบดเปเบเบ. เบเบปเบงเบขเปเบฒเบ, เบเบฒเบเบเบฐเบเบดเบเบฑเบเบเบญเบเบเบฑเบเปเบเบงเปเบฅเบฐเบซเบปเบงเบเปเปเปเบ ActiveMQ เบซเบผเบธเบเบฅเบปเบเบเปเบญเบเบงเปเบฒเบเปเบฒเบเบงเบเบเบนเปเบเปเบฅเบดเปเบเบเปเบเบเบธเบเบซเบกเบฒเบเบเบฒเบเบเบฒเบเปเบเบตเบเปเบ.
- เบชเบฒเบกเบฒเบเบเบฑเบเบเบฐ เปเบฒเบ เปเบเปเบเบฒเบกเปเบเบงเบเบญเบ; เบเปเบฒเบเบฒเบเบซเบเปเบฒเบซเบเบถเปเบเบเบตเปเบเบฑเบเบเบปเบเบกเบตเบเปเปเบเบงเบฒเบกเบชเบฒเบกเบฒเบเปเบฎเบฑเบเปเบเปเบเบฝเบเปเบเปเปเบเบเบงเบฒเบกเปเบงเบชเบนเบเบชเบธเบเบเบญเบเปเบเปเบ, เบซเบผเบฑเบเบเบฒเบเบเบฑเปเบเบกเบฑเบเบกเบตเบเบงเบฒเบกเบซเบกเบฒเบเบเบตเปเบเบฐเปเบเบเบญเบเปเบซเบเบทเบญเบเบปเบงเบขเปเบฒเบเบเบญเบเบเบฒเบเบซเบเปเบฒเบเบฝเบงเปเบเบทเปเบญเปเบเบตเปเบกเบเบฐเบชเบดเบเบเบดเบเบฒเบ.
- เบเปเบฒโเบเบฑเบโเบเบฒเบโเปเบเบปเปเบฒโเปเบเบดเบโเบเบฒเบโเปเบเบฑเบโเบฎเบฑเบโเบชเบฒโเปเบฅเบฐโเบเบฒเบโเบเบถเบโเบเปเปโเบเบงเบฒเบกโเบเบทเบโเปเบซเบกเปโ
เปเบเบทเปเบญเบเบฑเบเบฅเบธเบเบฑเบเบซเบกเบปเบเบเบตเป, Kafka เปเบเปเบฎเบฑเบเบฎเบญเบเปเบญเบปเบฒเบชเบฐเบเบฒเบเบฑเบเบเบฐเบเบฐเบเปเบฒเบเบตเปเบเปเบฒเบเบปเบเบเบฒเบฅเบฐเบเบปเบเบเบฒเบเปเบฅเบฐเบเบงเบฒเบกเบฎเบฑเบเบเบดเบเบเบญเบเบเบญเบเบฅเบนเบเบเปเบฒเปเบฅเบฐเบเบฒเบเบซเบเปเบฒเบเบฒเบเบชเบปเปเบเบเปเปเบเบงเบฒเบก. เบฎเบนเบเปเบเบ JMS เปเบกเปเบเบเบฒเบเบซเบเปเบฒเบซเบผเบฒเบเบฎเบฑเบเบเบธเบก, เบเปเบญเบเบเบตเปเบเบฒเบเบซเบเปเบฒเปเบกเปเบเบฎเบฑเบเบเบดเบเบเบญเบเบชเปเบฒเบฅเบฑเบเบเบฒเบเปเบเบเบขเบฒเบเบเปเปเบเบงเบฒเบกเปเบฅเบฐเบฅเบนเบเบเปเบฒเบเบฝเบเปเบเปเบเปเบญเบเบเบฑเบเบงเบปเบเบเปเบฝเบงเบเบฑเบเบเบฒเบเบชเบปเปเบเปเบฅเบฐเบฎเบฑเบเบเปเปเบเบงเบฒเบก. เปเบเบเบฒเบเบเบปเบเบเบฑเบเบเปเบฒเบก, Kafka เปเบกเปเบเบฅเบนเบเบเปเบฒเปเบเบฑเบเบชเบนเบเบเบฒเบ, เปเบเบเบฅเบนเบเบเปเบฒเปเบเปเบเบฐเบเบดเบเบฑเบเบซเบผเบฒเบเบฅเบฑเบเบชเบฐเบเบฐเบเบญเบเบเบฒเบเบซเบเปเบฒเปเบเบเบเบฑเปเบเปเบเบตเบก, เปเบเบฑเปเบ: เบเบฒเบเปเบเบเบขเบฒเบเบเปเปเบเบงเบฒเบกเบเบตเปเบเปเบฝเบงเบเปเบญเบเบขเปเบฒเบเบเบธเบเบเบดเบเปเบฒเบเบฑเบเบเบนเปเบเปเบฅเบดเปเบเบ, เปเบเบทเปเบญเปเบฅเบเบเปเบฝเบเบเบฑเบเบเบฒเบเบซเบเปเบฒเบเบตเปเปเบงเบเบตเปเบชเบธเบเปเบฅเบฐเบชเบฒเบกเบฒเบเบเบฐเบซเบเบฒเบเปเบเป. เบชเปเบฒเบฅเบฑเบเบเบฐเบเบฒเบเบปเบเบเบนเปเบเบตเปเปเบเปเปเบฎเบฑเบเบงเบฝเบเบเบฑเบเบฅเบฐเบเบปเบเบเบฒเบเบชเบปเปเบเบเปเปเบเบงเบฒเบกเปเบเบเบเบฑเปเบเปเบเบตเบก, เบเบฒเบเปเบฎเบฑเบเบงเบฝเบเบเบฑเบ Kafka เบฎเบฝเบเบฎเปเบญเบเปเบซเปเบกเบตเบเบฒเบเบเปเบฝเบเปเบเบเบเบทเปเบเบเบฒเบเบเบญเบเบเบดเบเปเบ.
เบเบดเบเบเบฒเบเบงเบดเบชเบฐเบงเบฐเบเปเบฒเบเบตเปเปเบเปเบเปเบฒเปเบเบชเบนเปเบเบฒเบเบชเปเบฒเบเปเบเบเบชเปเบฒเบเบเบทเปเบเบเบฒเบเบเบฒเบเบชเบปเปเบเบเปเปเบเบงเบฒเบกเบเบตเปเบกเบตเบเบงเบฒเบกเบชเบฒเบกเบฒเบเปเบเบเบฒเบเปเบเบตเปเบกเบเบถเปเบเปเบเบเบเปเบฒเบชเบฑเปเบเบซเบผเบฒเบเบเบฐเบซเบเบฒเบเปเบกเบทเปเบญเบเบฝเบเบเบฑเบเบเบฒเบเบซเบเปเบฒเบเบปเปเบงเปเบ. เบเบฑเปเบเบเบตเปเบเบงเบเปเบฎเบปเบฒเบเบฐเปเบซเบฑเบ, เบงเบดเบเบตเบเบฒเบเบเบตเปเบกเบฒเบเปเบญเบกเบเบฑเบเบเบฒเบเบเปเบฒเบเบฒเบ, เบเบถเปเบเบซเบกเบฒเบเบเบงเบฒเบกเบงเปเบฒ Kafka เบเปเปเปเบซเบกเบฒเบฐเบชเบปเบกเบชเปเบฒเบฅเบฑเบเบเบฒเบเบเบฐเปเบเบเบเบญเบเบงเบฝเบเปเบฅเบฐเบเบญเบเปเบงเบเบตเปเบเบดเบเบเบฑเปเบ.
เปเบเบเบเปเบฒเบฅเบญเบเบเบธเบเบซเบกเบฒเบเบเบฒเบเบเบฒเบเบฅเบงเบก
เปเบเบทเปเบญเบเบฐเบเบดเบเบฑเบเบเบฒเบกเบเปเปเบเปเบฒเบเบปเบเบเบตเปเปเบเปเบญเบฐเบเบดเบเบฒเบเปเบงเปเบเปเบฒเบเปเบเบดเบ, Kafka เปเบเปเบฅเบงเบกเปเบญเบปเบฒเบเบฒเบเปเบเบตเบเปเบเป - เบเบญเบเปเบฅเบฐเบเบฒเบเบชเบปเปเบเบเปเปเบเบงเบฒเบกเบเบธเบเบซเบเบถเปเบเบเบฒเบเปเบเปเบเบธเบเบซเบกเบฒเบเบเบฒเบเบเบฒเบเบเบฐเปเบเบเบซเบเบถเปเบ - เบซเบปเบงเบเปเป. เบเบตเปเปเบกเปเบเบเบงเบฒเบกเบชเบฑเบเบชเบปเบเบเบฑเบเบเบนเปเบเบตเปเปเบเปเปเบฎเบฑเบเบงเบฝเบเบเบฑเบเบฅเบฐเบเบปเบเบเบฒเบเบชเบปเปเบเบเปเปเบเบงเบฒเบก, เบเปเบญเบเบเบตเปเบเปเบฒเบงเปเบฒ "เบซเบปเบงเบเปเป" เบซเบกเบฒเบเปเบเบดเบเบเบปเบเปเบเบเบฒเบเบญเบญเบเบญเบฒเบเบฒเบเบเบตเป (เบเบฒเบเบซเบปเบงเบเปเป) เบเบฒเบเบญเปเบฒเบเปเบกเปเบเบเปเปเบเบปเบเบเบฒเบ. เบซเบปเบงเบเปเป Kafka เบเบงเบเบเบทเบเบเบดเบเบฒเบฅเบฐเบเบฒเปเบเบฑเบเบเบฐเปเบเบเบเบธเบเบซเบกเบฒเบเบเบฒเบเบเบฒเบเบเบฐเบชเบปเบก, เบเบฒเบกเบเบตเปเปเบเปเบเปเบฒเบเบปเบเปเบงเปเปเบเบเบปเบเปเบเบฐเบเปเบฒเบเบญเบเบเบถเปเบกเบซเบปเบงเบเบตเป.
เบชเปเบฒเบฅเบฑเบเบชเปเบงเบเบเบตเปเปเบซเบผเบทเบญเบเบญเบเบเบปเบเบเบตเป, เปเบงเบฑเปเบเปเบชเบเปเบเปเบงเปเบฒเบเบงเบเปเบฎเบปเบฒเบเบฐเบเบญเบเบขเปเบฒเบเบเบฐเปเบเปเบ, เบเปเบฒเบงเปเบฒ "เบซเบปเบงเบเปเป" เบเบฐเบซเบกเบฒเบเปเบเบดเบเบซเบปเบงเบเปเป Kafka.
เปเบเบทเปเบญเปเบเบปเปเบฒเปเบเบขเปเบฒเบเบชเบปเบกเบเบนเบเบงเปเบฒเบซเบปเบงเบเปเปเบเบฐเบเบดเบเบฑเบเปเบเบงเปเบเปเบฅเบฐเบเบฒเบเบฎเบฑเบเบเบฐเบเบฑเบเบชเบดเปเบเบเบตเปเบเบงเบเปเบเบปเบฒเบชเบฐเบซเบเบญเบ, เบเบงเบเปเบฎเบปเบฒเบเปเบฒเบญเบดเบเบเบตเปเบเบฐเบเปเบญเบเปเบเบดเปเบเบงเบดเบเบตเบเบฒเบเบเบฐเบเบดเบเบฑเบเปเบ Kafka.
เปเบเปเบฅเบฐเบซเบปเบงเบเปเปเปเบ Kafka เบกเบตเบเบฑเบเบเบถเบเบเบญเบเบเบปเบเปเบญเบ.
เบเบนเปเบเบฐเบฅเบดเบเบชเบปเปเบเบเปเปเบเบงเบฒเบกเปเบเบซเบฒ Kafka เบเบฝเบเปเบชเปเบเบฑเบเบเบถเบเบเบตเป, เปเบฅเบฐเบเบนเปเบเปเบฅเบดเปเบเบเบญเปเบฒเบเบเบฒเบเบเบฑเบเบเบถเบเปเบเบเปเบเปเบเบปเบงเบเบตเปเบเบตเปเบเปเบฒเบงเปเบเบเปเบฒเบเบซเบเปเบฒเบขเปเบฒเบเบเปเปเปเบเบทเปเบญเบ. เปเบเปเบฅเบฐเปเบฅเบเบฐ, Kafka เบเบฐเบฅเบถเบเบเบฒเบเบชเปเบงเบเปเบเบปเปเบฒเปเบเปเบเบตเปเบชเบธเบเบเบญเบเบเบฑเบเบเบถเบ, เบเปเปเบงเปเบฒเบเบฐเปเบเบฑเบเบเปเปเบเบงเบฒเบกเปเบเบเบฒเบเบชเปเบงเบเปเบซเบผเบปเปเบฒเบเบฑเปเบเปเบเปเบญเปเบฒเบเบซเบผเบทเบเปเป. เบชเปเบงเบเบชเบนเบเบเบฒเบเบเบญเบเบเบฒเบเบญเบญเบเปเบเบเบเบญเบ Kafka เปเบกเปเบเบงเปเบฒเบเบฒเบเบซเบเปเบฒเบเปเปเบชเบปเบเปเบเบงเปเบฒเบเปเปเบเบงเบฒเบกเบเบฐเบเบทเบเบญเปเบฒเบเบซเบผเบทเบเปเป - เบเบฑเปเบเปเบกเปเบเบเบงเบฒเบกเบฎเบฑเบเบเบดเบเบเบญเบเบเบญเบเบฅเบนเบเบเปเบฒ.
เบเปเบฒเบงเปเบฒ "เบเบฑเบเบเบถเบ" เปเบฅเบฐ "เบเบปเบงเบเบตเป" เบเปเปเบเบฒเบเบปเบเบขเบนเปเปเบ
เปเบญเบเบฐเบชเบฒเบ Kafka . เบเปเบฒเบชเบฑเบเบเปเบฒเบเปเบเบตเปเบกเบตเบเบทเปเบชเบฝเบเปเบซเบผเบปเปเบฒเบเบตเปเบเบทเบเบเปเบฒเปเบเปเบขเบนเปเบเบตเปเบเบตเปเปเบเบทเปเบญเบเปเบงเบเปเบซเปเบเบงเบฒเบกเปเบเบปเปเบฒเปเบ.
เบฎเบนเบเปเบเบเบเบตเปเปเบกเปเบเปเบเบเบเปเบฒเบเบเบฑเบเบขเปเบฒเบเบชเบดเปเบเปเบเบตเบเบเบฒเบ ActiveMQ, เบเปเบญเบเบเบตเปเบเปเปเบเบงเบฒเบกเบเบฒเบเปเบเบงเบเบฑเบเบซเบกเบปเบเบเบทเบเปเบเบฑเบเปเบงเปเปเบเบเบฑเบเบเบถเบเบเบฝเบงเบเบฑเบ, เปเบฅเบฐเบเบฒเบเบซเบเปเบฒเบเบฐเบซเบกเบฒเบเบเปเปเบเบงเบฒเบกเบเบตเปเบเบทเบเบฅเบถเบเบเบดเปเบกเบซเบผเบฑเบเบเบฒเบเบเบงเบเปเบเบปเบฒเปเบเปเบญเปเบฒเบ.
เบเบญเบเบเบตเปเปเบซเปเปเบฎเบปเบฒเบเบธเบเปเบเบฒเบฐเปเบฅเบดเบเปเปเบญเบเปเบถเปเบ เปเบฅเบฐเปเบเบดเปเบเบเบปเบเบเบฑเบเบเบถเบเบเบญเบเบซเบปเบงเบเปเปเปเบซเปเบฅเบฐเบญเบฝเบเบเบทเปเบก.
เบเบฑเบเบเบถเบ Kafka เบเบฐเบเบญเบเบเปเบงเบเบซเบผเบฒเบเบเบฒเบเบดเบเบฑเบ (
เบฎเบนเบเบเบต 3-1. Kafka Partitions
เปเบกเบทเปเบญเบเบนเปเบเบฐเบฅเบดเบเบชเบปเปเบเบเปเปเบเบงเบฒเบกเปเบเบซเบฒเบซเบปเบงเบเปเป Kafka, เบกเบฑเบเบเบฑเบเบชเบดเบเปเบเบงเปเบฒเบชเปเบงเบเปเบเบเบตเปเบเบฐเบชเบปเปเบเบเปเปเบเบงเบฒเบกเปเบเบซเบฒ. เบเบงเบเปเบฎเบปเบฒเบเบฐเปเบเบดเปเบเบเบตเปเปเบเบฅเบฒเบเบฅเบฐเบญเบฝเบเปเบเบตเปเบกเปเบเบตเบกเบเปเปเบกเบฒ.
เบเบณเบฅเบฑเบเบญเปเบฒเบเบเปเปเบเบงเบฒเบก
เบฅเบนเบเบเปเบฒเบเบตเปเบเปเบญเบเบเบฒเบเบญเปเบฒเบเบเปเปเบเบงเบฒเบกเบเบฐเบเบฑเบเบเบฒเบเบเบปเบงเบเบตเปเบเบตเปเบกเบตเบเบทเปเบเบตเปเปเบญเบตเปเบเบงเปเบฒ เบเบธเปเบกเบเบนเปเบเปเบฅเบดเปเบเบ, เปเบเบดเปเบเบเบตเปเปเบซเปเปเบซเบฑเบ เบเบปเบเปเบเบตเบ เบเปเปโเบเบงเบฒเบกโเปเบโเบเบฒเบโเปเบเปเบโเบเบฑเบโ. เบเบฒเบเบเบปเบเปเบเบตเบเปเบกเปเบเบเปเบฒเปเบซเบเปเบเบเบตเปเปเบเบตเปเบกเบเบถเปเบเบเบตเปเปเบฅเบตเปเบกเบเบปเปเบเบเบตเป 0 เปเบเบเบญเบเปเบฅเบตเปเบกเบเบปเปเบเบเบญเบเบเบฒเบเปเบเปเบเบเบฑเบ. เบเบธเปเบกเบเบนเปเบเปเบฅเบดเปเบเบเบเบตเป, เบญเปเบฒเบเบญเบตเบเปเบ API เบเปเบฒเบ group_id เบเบตเปเบเปเบฒเบเบปเบเปเบเบเบเบนเปเปเบเป, เบชเบญเบเบเปเบญเบเบเบฑเบ เบเบนเปเบเปเบฅเบดเปเบเบเบซเบผเบทเบฅเบฐเบเบปเบเบเบตเปเบกเบตเปเบซเบเบเบปเบ.
เบฅเบฐเบเบปเบเบชเบปเปเบเบเปเปเบเบงเบฒเบกเบชเปเบงเบเปเบซเบเปเบญเปเบฒเบเบเปเปเบกเบนเบเบเบฒเบเบเบฒเบเบเบฒเบเปเบเบเปเบเปเบซเบผเบฒเบเบเบปเบงเบขเปเบฒเบ เปเบฅเบฐเบซเบปเบงเบเปเปเปเบเบทเปเบญเบเบฐเบกเบงเบเบเบปเบเบเปเปเบเบงเบฒเบกเปเบเบเบฐเปเบฒเบ. เบเบฑเปเบเบเบฑเปเบ, เบเบปเบเบเบฐเบเบดเปเบฅเปเบงเบเบฐเบกเบตเบเบปเบงเบขเปเบฒเบเบเบนเปเบเปเบฅเบดเปเบเบเบเปเบฒเบเบงเบเบซเบผเบฒเบเบเบตเปเปเบเปเบเบเบฑเบเบเบธเปเบกเบเบนเปเบเปเบฅเบดเปเบเบเบเบฝเบงเบเบฑเบ.
เบเบฑเบเบซเบฒเบเบฒเบเบญเปเบฒเบเบชเบฒเบกเบฒเบเบชเบฐเปเบเบเปเบเปเบเบฑเปเบเบเบตเป:
- เบซเบปเบงโเบเปเปโเบกเบตโเบเบฒเบโเปเบเปเบโเบเบฑเบโเบซเบผเบฒเบโ
- เบซเบผเบฒเบเบเบธเปเบกเบเบญเบเบเบนเปเบเปเบฅเบดเปเบเบเบชเบฒเบกเบฒเบเบเปเบฒเปเบเปเบซเบปเบงเบเปเปเปเบเบซเบเบถเปเบเปเบเปเบงเบฅเบฒเบเบฝเบงเบเบฑเบ
- เบเบธเปเบกเบเบนเปเบเปเบฅเบดเปเบเบเบชเบฒเบกเบฒเบเบกเบตเบซเบผเบฒเบเบเบปเบงเบขเปเบฒเบเปเบเบเบเปเบฒเบเบซเบฒเบ
เบเบตเปโเปเบกเปเบโเปเบเบฑเบโเบเบฑเบโเบซเบฒโเบเบตเปโเบเปเปโเปเบกเปเบ trivial เบซเบผเบฒเบโเปเบเบดเบโเบซเบผเบฒเบโ. เปเบเบทเปเบญเปเบเบปเปเบฒเปเบเบงเบดเบเบตเบเบฒเบ Kafka เบเบฑเบเบเบฒเบเบเบฑเบเบเบงเบฒเบกเบชเปเบฒเบเบฑเบเบฅเบฐเบซเบงเปเบฒเบเบเบธเปเบกเบเบนเปเบเปเบฅเบดเปเบเบ, เบเบปเบงเบขเปเบฒเบเบเบญเบเบเบนเปเบเปเบฅเบดเปเบเบ, เปเบฅเบฐเบเบฒเบเปเบเปเบเบชเปเบงเบ, เปเบซเปเปเบเบดเปเบเบเบธเบเบเบญเบเบชเบฐเบเบฒเบเบฐเบเบฒเบเบเบฒเบเบญเปเบฒเบเบเบตเปเบชเบฑเบเบชเบปเบเบซเบผเบฒเบเบเบทเปเบเปเบฅเบทเปเบญเบเป.
เบเบนเปเบเปเบฅเบดเปเบเบเปเบฅเบฐเบเบธเปเบกเบเบนเปเบเปเบฅเบดเปเบเบ
เปเบซเปเปเบญเบปเบฒเปเบเบฑเบเบเบธเบเปเบฅเบตเปเบกเบเบปเปเบเบเบญเบเบซเบปเบงเบเปเปเบเบตเปเบกเบตเบเบฒเบเปเบเปเบเบเบฑเบเบซเบเบถเปเบ (
เบฎเบนเบ 3-2. เบเบนเปเบเปเบฅเบดเปเบเบเบญเปเบฒเบเบเบฒเบเบเบฒเบเปเบเปเบเบเบฑเบ
เปเบกเบทเปเบญเบเบปเบงเบขเปเบฒเบเบเบนเปเบเปเบฅเบดเปเบเบเปเบเบทเปเบญเบกเบเปเปเบเบฑเบ group_id เบเบญเบเบเบปเบเปเบญเบเบเบฑเบเบซเบปเบงเบเปเปเบเบตเป, เบกเบฑเบเปเบเปเบเบทเบเบกเบญเบเบซเบกเบฒเบเปเบซเปเบญเปเบฒเบ partition เปเบฅเบฐเบเบปเบเปเบเบตเบเปเบเบเบฒเบเบดเบเบฑเบเบเบฑเปเบ. เบเบณเปเปเปเบเบเบญเบเบเปเบฒเบเบปเบเปเบเบตเบเบเบตเปเปเบกเปเบเบชเบฒเบกเบฒเบเบเบณเบเบปเบเบเปเบฒเปเบเปเปเบเบฅเบนเบเบเปเบฒเปเบเบฑเบเบเบปเบงเบเบตเปเปเบเบซเบฒเบเบณเปเปเปเบเบซเบผเปเบฒเบชเบธเบ (เบเปเปเบเบงเบฒเบกเปเปเปเบชเบธเบ) เบซเบผเบท เบเบณเปเปเปเบเบเบณเบญเบดเบ (เบเปเปเบเบงเบฒเบกเปเบเบปเปเบฒเปเบเปเบเบตเปเบชเบธเบ). เบเบนเปเบเปเบฅเบดเปเบเบเบฎเปเบญเบเบเป (เปเบเบเบชเปเบฒเบซเบผเบงเบ) เบเปเปเบเบงเบฒเบกเบเบฒเบเบซเบปเบงเบเปเป, เปเบเบดเปเบเปเบฎเบฑเบเปเบซเปเบเบงเบเปเบเบปเบฒเบเบทเบเบญเปเบฒเบเบเบฒเบกเบฅเปเบฒเบเบฑเบเบเบฒเบเบเบฑเบเบเบถเบ.
เบเปเบฒเปเบซเบเปเบเบเบปเบเปเบเบตเบเปเบกเปเบเปเบเบฑเบเบเบปเบเบเบฐเบเบดเบเปเปเบเบฑเบ Kafka เปเบฅเบฐเบเบทเบเปเบเบฑเบเปเบงเปเปเบเบฑเบเบเปเปเบเบงเบฒเบกเปเบเบซเบปเบงเบเปเปเบเบฒเบเปเบ _consumer_offsets. เบเปเปเบเบงเบฒเบกเบเบตเปเบญเปเบฒเบเปเบฅเปเบงเบเบฑเบเบเปเปเบเบทเบเบฅเบถเบ, เบเปเปเปเบซเบกเบทเบญเบเบเบฑเบเบเบฒเบเบซเบเปเบฒเบเบปเบเบเบฐเบเบด, เปเบฅเบฐเบฅเบนเบเบเปเบฒเบชเบฒเบกเบฒเบ rewind เบเบปเบเปเบเบตเบเปเบเบทเปเบญเบเบฐเบกเบงเบเบเบปเบเบเบทเบเบเปเปเบเบงเบฒเบกเบเบตเปเปเบเบดเปเบเปเบฅเปเบง.
เปเบกเบทเปเบญเบเบนเปเบเปเบฅเบดเปเบเบเบเบตเปเบกเบตเปเบซเบเบเบปเบเบเบตเบชเบญเบเปเบเบทเปเบญเบกเบเปเปเปเบเบเปเบเป group_id เบเบตเปเปเบเบเบเปเบฒเบเบเบฑเบ, เบกเบฑเบเบเบฑเบเบเบฒเบเบเบปเบงเบเบตเปเบเบตเบชเบญเบเบเบตเปเบเปเปเบเบถเปเบเบเบฑเบเบเบปเบงเบเปเบฒเบญเบดเบ (
เบฎเบนเบเบเบต 3-3. เบเบนเปเบเปเบฅเบดเปเบเบเบชเบญเบเบเบปเบเปเบเบเบธเปเบกเบเบนเปเบเปเบฅเบดเปเบเบเบเบตเปเปเบเบเบเปเบฒเบเบเบฑเบเบญเปเบฒเบเบเบฒเบเบเบฒเบเปเบเปเบเบเบฑเบเบเบฝเบงเบเบฑเบ
เบเบนเปเบเปเบฅเบดเปเบเบเปเบเบเบธเปเบกเบเบนเปเบเปเบฅเบดเปเบเบ
เปเบกเบทเปเบญเบเบปเบงเบขเปเบฒเบเบเบนเปเบเปเบฅเบดเปเบเบเบซเบเบถเปเบเบญเปเบฒเบเบเปเปเบกเบนเบเบเบฒเบเบเบฒเบเบดเบเบฑเบ, เบกเบฑเบเบกเบตเบเบฒเบเบเบงเบเบเบธเบกเบขเปเบฒเบเปเบเบฑเบกเบเบตเปเบเบญเบเบเบปเบงเบเบตเปเปเบฅเบฐเบเบฐเบกเบงเบเบเบปเบเบเปเปเบเบงเบฒเบกเบเบฒเบกเบเบตเปเปเบเปเบญเบฐเบเบดเบเบฒเบเปเบงเปเปเบเบเบฒเบเบเปเบญเบ.
เบเปเบฒเบซเบผเบฒเบเปเบเบปเบงเบขเปเบฒเบเบเบญเบเบเบนเปเบเปเบฅเบดเปเบเบเปเบเปเปเบเบทเปเบญเบกเบเปเปเบเบฑเบ group_id เบเบฝเบงเบเบฑเบเบเบฑเบเบซเบปเบงเบเปเปเบเบตเปเบกเบตเบเบฒเบเปเบเปเบเบเบฑเบเบซเบเบถเปเบ, เบซเบผเบฑเบเบเบฒเบเบเบฑเปเบเบเบปเบงเบขเปเบฒเบเบเบตเปเปเบเบทเปเบญเบกเบเปเปเบชเบธเบเบเปเบฒเบเบเบฐเบเบทเบเบเบงเบเบเบธเบกเบเบปเบงเบเบตเปเปเบฅเบฐเบเบฒเบเปเบงเบฅเบฒเบเบฑเปเบเบกเบฑเบเบเบฐเปเบเปเบฎเบฑเบเบเปเปเบเบงเบฒเบกเบเบฑเบเบซเบกเบปเบ (
เบฎเบนเบ 3-4. เบเบนเปเบเปเบฅเบดเปเบเบเบชเบญเบเบเบปเบเปเบเบเบธเปเบกเบเบนเปเบเปเบฅเบดเปเบเบเบเบฝเบงเบเบฑเบเบญเปเบฒเบเบเบฒเบเบเบฒเบเปเบเปเบเบเบฑเบเบเบฝเบงเบเบฑเบ
เบฎเบนเบเปเบเบเบเบฒเบเบเบธเบเปเบเปเบเบเบตเป, เปเบเบเปเบฒเบเบงเบเบเบปเบงเบขเปเบฒเบเบเบญเบเบเบนเปเบเปเบฅเบดเปเบเบเปเบเบตเบเบเปเบฒเบเบงเบเบเบฒเบเปเบเปเบเบชเปเบงเบ, เบชเบฒเบกเบฒเบเบเบดเบเบงเปเบฒเปเบเบฑเบเบเบฐเปเบเบเบเบญเบเบเบนเปเบเปเบฅเบดเปเบเบเบชเบฐเปเบเบฒเบฐ. เบเบตเปเบชเบฒเบกเบฒเบเปเบเบฑเบเบเบฐเปเบซเบเบเบเปเบฒเบเปเบฒเบเบเปเบญเบเบเบฒเบ "active-passive" (เบซเบผเบท "hot-warm") clustering เบเบญเบเบเบปเบงเบขเปเบฒเบเบเบนเปเบเปเบฅเบดเปเบเบเบเบญเบเบเปเบฒเบ, เปเบเบดเบเปเบกเปเบเบงเปเบฒเบเบฒเบเบเปเบฒเปเบเบตเบเบเบฒเบเบเบญเบเบเบนเปเบเปเบฅเบดเปเบเบเบซเบผเบฒเบเปเบเบเบฐเบซเบเบฒเบ ("active-active" เบซเบผเบท "hot-hot") เปเบกเปเบเบเบปเบเบเบฐเบเบดเบซเบผเบฒเบเบเปเบงเบฒเบซเบผเบฒเบ. เบเบนเปเบเปเบฅเบดเปเบเบ.
เบเบถเบเบเบดเบเบณเบเบฒเบเปเบเบเบขเบฒเบเบเปเปเบเบงเบฒเบกเบเบตเปเบเบตเปเบญเบฐเบเบดเบเบฒเบเปเบงเปเบเปเบฒเบเปเบเบดเบเบเบฑเปเบเบญเบฒเบเปเบเบฑเบเปเบฅเบทเปเบญเบเปเบเบเบเบตเปเปเบกเบทเปเบญเบเบฝเบเบเบฝเบเบเบฑเบเบงเบดเบเบตเบเบฒเบเบเบญเบเปเบเบง JMS เบเบปเบเบเบฐเบเบด. เปเบเบฎเบนเบเปเบเบเบเบตเป, เบเปเปเบเบงเบฒเบกเบเบตเปเบเบทเบเบชเบปเปเบเปเบเบซเบฒเปเบเบงเบเบฐเบเบทเบเปเบเบเบขเบฒเบเบขเปเบฒเบเปเบเบปเปเบฒเบเบฝเบกเบเบฑเบเบฅเบฐเบซเบงเปเบฒเบเบชเบญเบเบเบนเปเบเปเบฅเบดเปเบเบ.
เบชเปเบงเบเบซเบผเบฒเบเปเบฅเปเบง, เปเบกเบทเปเบญเบเบงเบเปเบฎเบปเบฒเบชเปเบฒเบเบซเบผเบฒเบเปเบเบปเบงเบขเปเบฒเบเบเบญเบเบเบนเปเบเปเบฅเบดเปเบเบ, เบเบงเบเปเบฎเบปเบฒเปเบฎเบฑเบเบชเบดเปเบเบเบตเปเปเบเบทเปเบญเบเบธเบเปเบเปเบเบเปเปเบเบงเบฒเบกเบเบฐเบซเบเบฒเบ, เบซเบผเบทเปเบเบทเปเบญเปเบเบตเปเบกเบเบงเบฒเบกเปเบงเบเบญเบเบเบฒเบเบญเปเบฒเบ, เบซเบผเบทเปเบเบตเปเบกเบเบงเบฒเบกเบซเบกเบฑเปเบเบเบปเบเบเบญเบเบเบฐเบเบงเบเบเบฒเบเบญเปเบฒเบ. เปเบเบทเปเบญเบเบเบฒเบเบเบฝเบเปเบเปเบซเบเบถเปเบเบเบปเบงเบขเปเบฒเบเบเบนเปเบเปเบฅเบดเปเบเบเบชเบฒเบกเบฒเบเบญเปเบฒเบเบเปเปเบกเบนเบเบเบฒเบเบเบฒเบเบดเบเบฑเบเบซเบเบถเปเบเปเบเปเบงเบฅเบฒเบเบฑเปเบ, เบกเบฑเบเบเบฑเบเบฅเบธเปเบเปเปเบเบงเปเบเปเบ Kafka?
เบงเบดเบเบตเบซเบเบถเปเบเบเบตเปเบเบฐเปเบฎเบฑเบเบเบทเบเบฒเบเปเบเปเบเบปเบงเบขเปเบฒเบเบเบนเปเบเปเบฅเบดเปเบเบเบเบฝเบงเปเบเบทเปเบญเบญเปเบฒเบเบเปเปเบเบงเบฒเบกเบเบฑเบเบซเบกเบปเบเปเบฅเบฐเบชเบปเปเบเปเบซเปเบเบงเบเปเบเบปเบฒเปเบเบซเบฒเบซเบปเบงเบเปเป. เปเบเบเบฐเบเบฐเบเบตเปเบงเบดเบเบตเบเบฒเบเบเบตเปเปเบเบตเปเบกเบเบฐเบเบงเบเบเบฒเบเบเบธเบเปเบเปเบ, เบกเบฑเบเปเบเบตเปเบกเบเบงเบฒเบกเบชเบฑเบเบชเบปเบเบเบญเบเปเบซเบเบเบปเบเบเบญเบเบเบนเปเบเปเบฅเบดเปเบเบเปเบฅเบฐเบเปเปเบกเบตเบซเบเบฑเบเบเบตเปเบเบฐเปเบเบตเปเบกเบเบงเบฒเบกเปเบเบเปเบฎเบเบเบญเบเบฅเบฐเบเบปเบเบเบฒเบเบญเปเบฒเบ. เบเปเบฒเบซเบเบถเปเบเบชเปเบฒเปเบเบปเบฒเบเบญเบเบเบนเปเบเปเบฅเบดเปเบเบเบซเบผเบธเบเบฅเบปเบเบเปเบญเบเบเบงเบฒเบกเบฅเบปเปเบกเปเบซเบผเบงเบเบญเบเบเบฐเบฅเบฑเบเบเบฒเบเบซเบผเบทเปเบซเบเบเบฒเบเบเบตเปเบเปเบฒเบเบเบทเบเบฑเบ, เบซเบผเบฑเบเบเบฒเบเบเบฑเปเบเบเบฒเบเบซเบฑเบเบฅเบปเบเบขเบธเบเปเบเบปเบฒ.
เบงเบดเบเบตเบเบฒเบ canonical เปเบเบทเปเบญเปเบเปเปเบเบเบฑเบเบซเบฒเบเบตเปเปเบ Kafka เปเบกเปเบเบเบฒเบเปเบเป bะเปเบเปเบโเบเบฑเบโเปเบเบตเปเบกโเปเบเบตเบกโ.
เบเบฒเบเปเบเปเบเบชเปเบงเบ
เบเบฒเบเปเบเปเบเบชเปเบงเบเปเบกเปเบเบเบปเบเปเบเบเบปเปเบเบเปเบชเปเบฒเบฅเบฑเบเบเบฒเบเบเบฐเบซเบเบฒเบเบเบฒเบเบญเปเบฒเบเปเบฅเบฐเบเบฒเบเบเบฐเบซเบเบฒเบเบซเบปเบงเบเปเปเปเบเบตเบเปเบเบเบงเบดเบเบเบญเบเบเบปเบงเบขเปเบฒเบเบเบฒเบเบซเบเปเบฒเบเบฝเบง. เปเบเบทเปเบญเปเบเบปเปเบฒเปเบเปเบฅเบทเปเบญเบเบเบตเปเปเบเปเบเบตเบเบถเปเบ, เปเบซเปเบเบดเบเบฒเบฅเบฐเบเบฒเบชเบฐเบเบฒเบเบฐเบเบฒเบเบเบตเปเบกเบตเบซเบปเบงเบเปเปเบเบตเปเบกเบตเบชเบญเบเบเบฒเบเบดเบเบฑเบเปเบฅเบฐเบซเบเบถเปเบเบเบนเปเบเปเบฅเบดเปเบเบเบเบญเบเบซเบปเบงเบเปเปเบเบตเป (
เบฎเบนเบ 3-5. เบเบนเปเบเปเบฅเบดเปเบเบเบเบปเบเบซเบเบถเปเบเบญเปเบฒเบเบเบฒเบเบซเบผเบฒเบเบเบฒเบเบดเบเบฑเบ
เปเบเบชเบฐเบเบฒเบเบฐเบเบฒเบเบเบตเป, เบเบนเปเบเปเบฅเบดเปเบเบเปเบเปเบฎเบฑเบเบเบฒเบเบเบงเบเบเบธเบกเบเบปเบงเบเบตเปเบเบตเปเบชเบญเบเบเปเบญเบเบเบฑเบ group_id เบเบญเบเบกเบฑเบเบขเบนเปเปเบเบเบฑเบเบชเบญเบเบเบฒเบเบดเบเบฑเบเปเบฅเบฐเปเบฅเบตเปเบกเบญเปเบฒเบเบเปเปเบเบงเบฒเบกเบเบฒเบเบเบฑเบเบชเบญเบเบเบฒเบเบดเบเบฑเบ.
เปเบกเบทเปเบญเบเบนเปเบเปเบฅเบดเปเบเบเปเบเบตเปเบกเปเบเบตเบกเบชเปเบฒเบฅเบฑเบ group_id เบเบฝเบงเบเบฑเบเบเบทเบเปเบเบตเปเบกเปเบชเปเบซเบปเบงเบเปเปเบเบตเป, Kafka เบเบฑเบเบชเบฑเบเบซเบเบถเปเบเบเบญเบเบเบฒเบเบดเบเบฑเบเบเบฒเบเบเบนเปเบเปเบฅเบดเปเบเบเบเปเบฒเบญเบดเบเปเบเบซเบฒเบเบนเปเบเปเบฅเบดเปเบเบเบเบตเบชเบญเบ. เบซเบผเบฑเบเบเบฒเบเบเบฑเปเบ, เปเบเปเบฅเบฐเบเบปเบงเบขเปเบฒเบเบเบญเบเบเบนเปเบเปเบฅเบดเปเบเบเบเบฐเบญเปเบฒเบเบเบฒเบเบเบฒเบเบชเปเบงเบเบซเบเบถเปเบเบเบญเบเบซเบปเบงเบเปเป (
เปเบเบทเปเบญเปเบซเปเปเบเปเปเบเบงเปเบฒเบเปเปเบเบงเบฒเบกเบเบทเบเบเบฐเบกเบงเบเบเบปเบเบเบฐเบซเบเบฒเบเปเบ 20 เบเบฐเบเบนเป, เบเปเบฒเบเบเปเบฒเปเบเบฑเบเบเปเบญเบเบกเบตเบขเปเบฒเบเบซเบเปเบญเบ 20 partitions. เบเปเบฒเบกเบตเบเบฒเบเปเบเปเบเบชเปเบงเบเบซเบเปเบญเบ, เบเปเบฒเบเบเบฐเบเบทเบเบเบฐเปเบงเปเบเบฑเบเบเบนเปเบเปเบฅเบดเปเบเบเบเบตเปเบเปเปเบกเบตเบซเบเบฑเบเบเบตเปเบเบฐเปเบฎเบฑเบเบงเบฝเบ, เบเบฑเปเบเบเบตเปเปเบเปเบญเบฐเบเบดเบเบฒเบเปเบงเปเบเปเบญเบเบซเบเปเบฒเบเบตเปเปเบเบเบฒเบเบชเบปเบเบเบฐเบเบฒเบเบญเบเบเบนเปเบเปเบฅเบดเปเบเบเบชเบฐเปเบเบฒเบฐ.
เบฎเบนเบ 3-6. เบเบนเปเบเปเบฅเบดเปเบเบเบชเบญเบเบเบปเบเปเบเบเบธเปเบกเบเบนเปเบเปเบฅเบดเปเบเบเบเบฝเบงเบเบฑเบเบญเปเบฒเบเบเบฒเบเบเบฒเบเปเบเปเบเบเบฑเบเบเบตเปเปเบเบเบเปเบฒเบเบเบฑเบ
เปเบเบเบเบฒเบเบเบตเปเบซเบผเบธเบเบฅเบปเบเบขเปเบฒเบเบซเบผเบงเบเบซเบผเบฒเบเบเบญเบเบเบงเบฒเบกเบชเบฑเบเบชเบปเบเบเบญเบเบเบฒเบเบซเบเปเบฒ Kafka เปเบกเบทเปเบญเบเบฝเบเบเบฑเบเบเบฒเบเปเบเบเบขเบฒเบเบเปเปเบเบงเบฒเบกเบเบตเปเบเปเบญเบเบเบฒเบเปเบเบทเปเบญเบฎเบฑเบเบชเบฒเปเบเบง JMS. เปเบเบเบตเปเบเบตเปเบเปเบฒเบเบเปเปเบเปเบฒเปเบเบฑเบเบเปเบญเบเบเบฑเบเบงเบปเบเบเปเบฝเบงเบเบฑเบเบเบธเบเบเปเปเปเบเบเบตเป:
- เบเบนเปเบเปเบฅเบดเปเบเบเปเบเบเบงเบเปเบเปเบฎเบฑเบเบเปเปเบเบงเบฒเบกเบเปเปเปเบ, เปเบเบเบญเบตเบเปเบชเปเบเบฒเบเบเบฑเบเบชเบฑเบเบฎเบญเบเบงเบฝเบ, เบเบงเบฒเบกเบญเบฒเบเบชเบฒเบกเบฒเบเปเบเบเบฐเบเบธเบเบฑเบเบเบญเบ prefetch buffers, เบซเบผเบทเบเปเปเบเบงเบฒเบกเบเบตเปเบเปเบฒเบเบกเบฒ (เบชเปเบฒเบฅเบฑเบเบเบธเปเบกเบเปเปเบเบงเบฒเบก JMS).
- เบเปเปเบเบงเบฒเบกเปเบเบเบทเบเบชเบปเปเบเปเบเบซเบฒเบเบนเปเบเปเบฅเบดเปเบเบเปเบฅเบฐเบงเปเบฒเบเบงเบเปเบเบปเบฒเบเบงเบเบเบฐเบเบทเบเบชเบปเปเบเบเบทเบเปเบซเบกเปเปเบเบเปเบฅเบฐเบเบตเบเบตเปเบฅเบปเปเบกเปเบซเบฅเบง.
เบเบฒเบเบซเบเปเบฒ Kafka เบเบฑเบเบซเบกเบปเบเบเบตเปเบเปเบญเบเปเบฎเบฑเบเบเบทเบเบฒเบเบชเบปเปเบเบเปเปเบเบงเบฒเบกเบเบฒเบกเบฅเปเบฒเบเบฑเบเปเบเบซเบฒเบเบนเปเบเปเบฅเบดเปเบเบเปเบกเบทเปเบญเบเบนเปเบชเบธเบเบเปเบฒเบเบฎเปเบญเบเบเปเปเบซเปเปเบเบปเบฒเปเบเบปเปเบฒ.
เบขเปเบฒเบเปเบเบเปเบเบฒเบก, เบเปเปเบเปเบฒเบเบปเบเบชเปเบฒเบฅเบฑเบเบเบฒเบเบเบฐเบซเบเบฒเบเบเบฒเบเบญเปเบฒเบเบซเบเบฑเบเบชเบทเปเบฅเบฐเบเบฒเบเบชเบปเปเบเบเบทเบเบเปเปเบเบงเบฒเบกเบเบตเปเบฅเบปเปเบกเปเบซเบฅเบงเบเปเปเปเบเปเปเบ - เบเบงเบฒเบกเบฎเบฑเบเบเบดเบเบเบญเบเบชเปเบฒเบฅเบฑเบเบเบงเบเปเบเบปเบฒเบเบฝเบเปเบเปเบเปเบฒเบเบเบฒเบเบเบฒเบเบซเบเปเบฒเปเบเบซเบฒเบฅเบนเบเบเปเบฒ. เบเบตเปเบซเบกเบฒเบเบเบงเบฒเบกเบงเปเบฒเบเบงเบเปเบเบปเบฒเบเปเบญเบเปเบเปเบฎเบฑเบเบเบฒเบเบเบดเบเบฒเบฅเบฐเบเบฒเปเบเบฅเบฐเบซเบฑเบเบเบญเบเบเปเบฒเบ.
เบเบณเบฅเบฑเบเบชเบปเปเบเบเปเปเบเบงเบฒเบก
เบกเบฑเบเปเบเบฑเบเบเบงเบฒเบกเบฎเบฑเบเบเบดเบเบเบญเบเบเบญเบเบเบนเปเบเบฐเบฅเบดเบเบเปเปเบเบงเบฒเบกเบเบฑเปเบเบเบตเปเบเบฐเบเบฑเบเบชเบดเบเปเบเบงเปเบฒ partition เปเบเบเบตเปเบเบฐเบชเบปเปเบเบเปเปเบเบงเบฒเบกเปเบเบซเบฒ. เปเบเบทเปเบญเปเบเบปเปเบฒเปเบเบเบปเบเปเบเบเบตเปเบชเบดเปเบเบเบตเปเบเบทเบเปเบฎเบฑเบ, เบเปเบญเบเบญเบทเปเบ เปเบปเบ เบเบงเบเปเบฎเบปเบฒเบเปเบญเบเบเบดเบเบฒเบฅเบฐเบเบฒเบชเบดเปเบเบเบตเปเบเบงเบเปเบฎเบปเบฒเบชเบปเปเบเบเบปเบงเบเบดเบ.
เปเบเบเบฐเบเบฐเบเบตเปเปเบ JMS เบเบงเบเปเบฎเบปเบฒเปเบเปเปเบเบเบชเปเบฒเบเบเปเปเบเบงเบฒเบกเบเบตเปเบกเบต metadata (เบชเปเบงเบเบซเบปเบงเปเบฅเบฐเบเบธเบเบชเบปเบกเบเบฑเบ) เปเบฅเบฐเบฎเปเบฒเบเบเบฒเบเบเบตเปเบกเบต payload (payload), เปเบ Kafka เบเปเปเบเบงเบฒเบกเปเบกเปเบ. เบเบนเป "key-value". เบเปเปเบเบงเบฒเบก payload เบเบทเบเบชเบปเปเบเปเบเปเบเบฑเบเบกเบนเบเบเปเบฒ. เปเบเบเบฒเบเบเบปเบเบเบฑเบเบเปเบฒเบก, เบเบตเปเบชเปเบฒเบเบฑเบเปเบกเปเบเบเบทเบเบเปเบฒเปเบเปเบเบปเปเบเบเปเบชเปเบฒเบฅเบฑเบเบเบฒเบเปเบเปเบเบชเปเบงเบเปเบฅเบฐเบเปเบญเบเบกเบต เบซเบผเบฑเบเปเบซเบเบเบปเบเบเบฒเบเบเบธเบฅเบฐเบเบดเบเปเบเบทเปเบญเปเบญเบปเบฒเบเปเปเบเบงเบฒเบกเบเบตเปเบเปเบฝเบงเบเปเบญเบเบขเบนเปเปเบเบเบฒเบเบดเบเบฑเบเบเบฝเบงเบเบฑเบ.
เปเบเบเบปเบเบเบต 2, เบเบงเบเปเบฎเบปเบฒเปเบเปเบเบถเบเบชเบฒเบซเบฒเบฅเบทเบชเบฐเบเบฒเบเบฐเบเบฒเบเบเบฒเบเบเบฐเบเบฑเบเบญเบญเบเปเบฅเบเปเบเบตเปเปเบซเบเบเบฒเบเบเบตเปเบเปเบฝเบงเบเปเบญเบเบเปเบญเบเปเบเปเบฎเบฑเบเบเบฒเบเบเบธเบเปเบเปเบเบเบฒเบกเบฅเปเบฒเบเบฑเบเปเบเบเบเบนเปเบเปเบฅเบดเปเบเบเบเบฝเบง:
- เบเบฑเบเบเบตเบเบนเปเปเบเปเบเบทเบเบเบฑเปเบเบเปเบฒ.
- เปเบเบดเบเบเบทเบเปเบเบปเปเบฒเบเบฑเบเบเบต.
- เบเบฒเบเปเบเบตเบกเบเบฑเบเปเบกเปเบเปเบฎเบฑเบเปเบซเปเบเบญเบเปเบเบดเบเบญเบญเบเบเบฒเบเบเบฑเบเบเบต.
เบเปเบฒเปเบเปเบฅเบฐเปเบซเบเบเบฒเบเปเบกเปเบเบเปเปเบเบงเบฒเบกเบเบตเปเบฅเบปเบเปเบเบซเบปเบงเบเปเปเปเบเบซเบเบถเปเบ, เบซเบผเบฑเบเบเบฒเบเบเบฑเปเบเบฅเบฐเบซเบฑเบเบเปเบฒเบกเบฐเบเบฒเบเบเบฐเปเบเบฑเบ ID เบเบฑเบเบเบต.
เปเบกเบทเปเบญเบเปเปเบเบงเบฒเบกเบเบทเบเบชเบปเปเบเปเบเบเปเบเป Kafka Producer API, เบกเบฑเบเบเบทเบเบชเบปเปเบเบเบฑเบเบเบฑเบเบเบฑเบเบเบฒเบเบดเบเบฑเบเบเบตเปเปเบซเปเบเปเปเบเบงเบฒเบกเปเบฅเบฐเบชเบฐเบเบฒเบเบฐเบเบฐเบเบธเบเบฑเบเบเบญเบเบเบธเปเบก Kafka, เบชเบปเปเบเบเบทเบ ID เบเบญเบเบเบฒเบเบดเบเบฑเบเบเบตเปเบเปเปเบเบงเบฒเบกเบเบงเบเบเบทเบเบชเบปเปเบ. เบเบธเบเบชเบปเบกเบเบฑเบเบเบตเปเบเบทเบเบเบฐเบเบดเบเบฑเบเบขเบนเปเปเบ Java เบเปเบฒเบเบชเปเบงเบเบเบดเบเบเปเปเบเบญเบ Partitioner.
เบเบฒเบเปเบเปเบเบญเบเบเบตเปเปเบเบดเปเบเบเบทเบงเปเบฒ:
interface Partitioner {
int partition(String topic,
Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster);
}
เบเบฒเบเบเบฑเบเบเบฑเปเบเบเบฐเบเบดเบเบฑเบ Partitioner เปเบเปเบฅเบฐเบเบปเบเบเบฒเบเบเบฑเปเบเปเบเบฑเบเปเบเบเบเบปเปเบงเปเบเปเบเบเบญเบเบเบปเปเบเปเบเบทเปเบญเบเบณเบเบปเบเบเบฒเบเปเบเปเบเบเบฒเบเบดเบเบฑเบ, เบซเบผเบทเปเบเบเบฎเบญเบเบเบปเบงเบเปเบฒเบเปเปเบกเบตเบเบฒเบเบฅเบฐเบเบธเบฅเบฐเบซเบฑเบ. เบเปเบฒเปเบฅเบตเปเบกเบเบปเปเบเบเบตเปเปเบฎเบฑเบเบงเบฝเบเปเบเปเบเบตเปเบเบเปเบฅเบฐเบเบตเบซเบผเบฒเบเบเบตเปเบชเบธเบ. เบขเปเบฒเบเปเบเบเปเบเบฒเบก, เปเบเบญเบฐเบเบฒเบเบปเบ, เบเปเบฒเบเบเปเบญเบเบเบฒเบเบเบฝเบเบเบญเบเบเปเบฒเบเปเบญเบ.
เบเบฝเบเบเบธเบเบเบฐเบชเบฒเบเบเบฒเบเปเบเปเบเบชเปเบงเบเบเบญเบเบเปเบฒเบเปเบญเบ
เปเบซเปเปเบเบดเปเบเบเบปเบงเบขเปเบฒเบเบเบตเปเบเปเบฒเบเบเปเบญเบเบเบฒเบเบเบตเปเบเบฐเบชเบปเปเบ metadata เบเปเบญเบกเบเบฑเบ payload เบเปเปเบเบงเบฒเบก. payload เปเบเบเบปเบงเบขเปเบฒเบเบเบญเบเบเบงเบเปเบฎเบปเบฒเปเบกเปเบเบเปเบฒเปเบเบฐเบเปเบฒเปเบเบทเปเบญเปเบฎเบฑเบเปเบซเปเปเบเบดเบเบเบฒเบเปเบเบปเปเบฒเปเบเปเบเบเบฑเบเบเบตเปเบเบก. เบเปเบฒเปเบเบฐเบเปเบฒเปเบกเปเบเบเบฒเบเบชเบดเปเบเบเบฒเบเบขเปเบฒเบเบเบตเปเบเบงเบเปเบฎเบปเบฒเบเปเบญเบเบเบฒเบเบเบตเปเบเบฐเปเบเปเบฎเบฑเบเบเบฒเบเบฎเบฑเบเบเบฐเบเบฑเบเบงเปเบฒเบเบฐเบเปเปเบเบทเบเบเบฑเบเปเบเบเปเบเบฅเบฐเบเบปเบเบชเบฒเบเบชเบปเปเบเปเบฅเบฐเบเปเบญเบเบเบฒเบเปเบซเปเปเบเปเปเบเบงเปเบฒเบเบฝเบเปเบเปเบฅเบฐเบเบปเบเบชเบฒเบเบเปเปเบฒเบเบตเปเปเบเบทเปเบญเบเบทเปเบเปเบชเบฒเบกเบฒเบเบฅเบดเปเบฅเบตเปเบกเบเปเบฒเปเบเบฐเบเปเบฒเบเบฑเปเบ. เปเบโเบเปโเบฅเบฐโเบเบตโเบเบตเปโ, เบฅเบฐโเบเบปเบโเบเบฒเบโเบชเบปเปเบโเปเบฅเบฐโเบเบฒเบโเบฎเบฑเบโเปเบเปโเบเบปเบโเบฅเบปเบโเบเปเบฝเบงโเบเบฑเบโเบเบฒเบโเบเปเบฒโเปเบเปโเบฅเบฒเบโเปเบเบฑเบโเปเบเบทเปเบญโเบเบงเบโเบชเบญเบโเบเปเปโเบเบงเบฒเบกโ.
เปเบ JMS เบเบปเบเบเบฐเบเบด, เบเบงเบเปเบฎเบปเบฒเบเบฝเบเปเบเปเบเปเบฒเบเบปเบเบเบธเบเบชเบปเบกเบเบฑเบ "เบฅเบฒเบเปเบเบฑเบเบเปเปเบเบงเบฒเบก" เปเบฅเบฐเปเบเบตเปเบกเบกเบฑเบเปเบชเปเบเปเปเบเบงเบฒเบก. เบขเปเบฒเบเปเบเบเปเปเบเบฒเบก, Kafka เบเปเปเปเบเปเปเบซเปเบเบงเบเปเบฎเบปเบฒเบกเบตเบเบปเบเปเบเบชเปเบฒเบฅเบฑเบเบเบฒเบเบเปเบฒเบเบเบญเบ metadata, เบเบฝเบเปเบเปเบฅเบฐเบซเบฑเบเปเบฅเบฐเบกเบนเบเบเปเบฒ.
เปเบเบทเปเบญเบเบเบฒเบเบกเบนเบเบเปเบฒเปเบกเปเบ payload เบเบฒเบเปเบญเบเบเบฐเบเบฒเบเบฒเบเบเบตเปเบกเบตเบเบงเบฒเบกเบเบทเปเบชเบฑเบเบเบตเปเบเบงเบเปเบฎเบปเบฒเบเปเบญเบเบเบฒเบเบเบตเปเบเบฐเบฎเบฑเบเบชเบฒ, เบเบงเบเปเบฎเบปเบฒเบเปเปเบกเบตเบเบฒเบเปเบฅเบทเบญเบเบเบตเปเบเบฐเบเปเบฒเบเบปเบเปเบเบเบชเปเบฒเบเบเปเปเบกเบนเบเบเบตเปเบเบฐเปเบเปเปเบเบเบต. เบชเบปเบกเบกเบธเบเบงเปเบฒเบเบงเบเปเบฎเบปเบฒเบเปเบญเบเบเบฒเบ ID เบเบฑเบเบเบตเบชเปเบฒเบฅเบฑเบเบเบฒเบเปเบเปเบเบชเปเบงเบ, เปเบเบทเปเบญเบเบเบฒเบเบเปเปเบเบงเบฒเบกเบเบฑเบเบซเบกเบปเบเบเบตเปเบเปเบฝเบงเบเปเบญเบเบเบฑเบเบเบฑเบเบเบตเบเปเบญเบเปเบเปเบฎเบฑเบเบเบฒเบเบเบฐเบกเบงเบเบเบปเบเบเบฒเบกเบฅเปเบฒเบเบฑเบ, เบเบงเบเปเบฎเบปเบฒเบเบฐเบกเบตเปเบเบเบชเปเบฒเบ JSON เบเปเปเปเบเบเบตเป:
{
"signature": "541661622185851c248b41bf0cea7ad0",
"accountId": "10007865234"
}
เปเบเบทเปเบญเบเบเบฒเบเบงเปเบฒเบกเบนเบเบเปเบฒเบเบญเบเบฅเบฒเบเปเบเบฑเบเบเบฐเปเบเบเบเปเบฒเบเบเบฑเบเปเบเบเบฒเบก payload, เบเบธเบเบเบฐเบชเบฒเบ hashing เปเบฅเบตเปเบกเบเบปเปเบเบเบญเบเบชเปเบงเบเบเบดเบเบเปเปเบเบญเบ Partitioner เบเบฐเบเปเปเปเบเบฑเบเบเบธเปเบกเบเปเปเบเบงเบฒเบกเบเบตเปเบเปเบฝเบงเบเปเบญเบ. เบเบฑเปเบเบเบฑเปเบ, เบเบงเบเปเบฎเบปเบฒเบเบฐเบเปเบญเบเบเบฝเบเบเบธเบเบเบฐเบชเบฒเบเบเบญเบเบเบงเบเปเบฎเบปเบฒเปเบญเบเบเบตเปเบเบฐเบงเบดเปเบเบฒเบฐเบเบตเปเบชเปเบฒเบเบฑเบเบเบตเปเปเบฅเบฐเปเบเปเบเบชเปเบงเบเบกเบนเบเบเปเบฒ accountId.
Kafka เบเบฐเบเบญเบเบกเบต checksums เปเบเบทเปเบญเบเบงเบเบเบปเบเบเบฒเบเบชเปเปเบฅเบฒเบเบเบฑเบเบซเบผเบงเบเบเบญเบเบเปเปเบเบงเบฒเบกเปเบเบฎเปเบฒเบเปเบฅเบฐเบกเบตเบเบธเบเบเบฐเบชเบปเบกเบเบฑเบเบเบงเบฒเบกเบเบญเบเปเบเบขเปเบฒเบเปเบเบฑเบกเบเบตเป. เปเบเบดเบเปเบกเปเบเบงเปเบฒ, เบเบงเบฒเบกเบเปเบญเบเบเบฒเบเบชเบฐเปเบเบฒเบฐเบเบญเบเบญเบธเบเบชเบฒเบซเบฐเบเปเบฒ, เปเบเบฑเปเบเบซเบเบถเปเบเบเปเบฒเบเปเบเบดเบ, เบเบฒเบเบเบฑเปเบเบเบฒเบเบปเบ.
เบเบธเบเบเบฐเบชเบฒเบเบเบฒเบเปเบเปเบเบชเปเบงเบเบเบญเบเบเบนเปเปเบเปเบเปเบญเบเบฎเบฑเบเบเบฐเบเบฑเบเบงเปเบฒเบเปเปเบเบงเบฒเบกเบเบตเปเบเปเบฝเบงเบเปเบญเบเบเบฑเบเบซเบกเบปเบเบชเบดเปเบเบชเบธเบเบฅเบปเบเปเบเบเบฒเบเปเบเปเบเบเบฑเบเบเบฝเบงเบเบฑเบ. เปเบเบเบฐเบเบฐเบเบตเปเบเบตเปเปเบเบดเปเบเบเบทเบงเปเบฒเบเปเบฒเบเบเบฒเบ, เบเบงเบฒเบกเบเปเบญเบเบเบฒเบเบชเบฒเบกเบฒเบเบชเบฑเบเบชเบปเบเปเบเบเบเบงเบฒเบกเบชเปเบฒเบเบฑเบเบเบญเบเบเปเบฒเบชเบฑเปเบเบเปเปเบเบงเบฒเบกเบเบตเปเบเปเบฝเบงเบเปเบญเบเปเบฅเบฐเบงเบดเบเบตเบเบฒเบเปเบเปเปเบเบเปเบฒเบเบงเบเบเบฒเบเปเบเปเบเบชเปเบงเบเปเบเบซเบปเบงเบเปเปเปเบเบซเบเบถเปเบ.
เบเปเบฒเบเบงเบเบเบญเบเบเบฒเบเปเบเปเบเบชเปเบงเบเปเบเบซเบปเบงเบเปเปเปเบเบซเบเบถเปเบเบชเบฒเบกเบฒเบเบเปเบฝเบเปเบเบเปเบเปเบฅเบเบฐเปเบงเบฅเบฒ, เบเปเบญเบเบงเปเบฒเบเบงเบเปเบเบปเบฒเบชเบฒเบกเบฒเบเปเบเบตเปเบกเปเบเปเบเปเบฒเบเบฒเบเบเบฐเบฅเบฒเบเบญเบเปเบเบตเบเบเบงเบฒเบกเบเบฒเบเบซเบงเบฑเบเปเบเบทเปเบญเบเบเบปเปเบ. เบเบฑเปเบเบเบฑเปเบ, เบเบฐเปเบเบเปเปเบเบงเบฒเบกเบชเบฒเบกเบฒเบเปเบเบทเปเบญเบกเปเบเบเบเบฑเบเบเบฒเบเบดเบเบฑเบเบเบตเปเบเบงเบเปเบเบปเบฒเบเบทเบเบชเบปเปเบเปเบเปเบเบทเปเบญเบเบเบปเปเบ, เปเบเบดเปเบเบซเบกเบฒเบเปเบเบดเบเบเบฒเบเปเบเปเบเบชเปเบงเบเบเบญเบเบฅเบฑเบเบฅเบฐเบซเบงเปเบฒเบเบเบนเปเบเบฐเบฅเบดเบ.
เบเบฑเบเปเบเบญเบทเปเบเบเบตเปเบเบงเบเบเบดเบเบฒเบฅเบฐเบเบฒเปเบกเปเบเบเบฒเบเปเบเปเบเบฐเบเบฒเบเบเบญเบเบเปเปเบเบงเบฒเบกเปเบเบเบปเปเบงเบเบฒเบเปเบเปเบเบเบฑเบ. เปเบเบเบเบปเบเบเบฐเบเบด, เบเบฐเปเบเบเปเปเปเบเปเบเบทเบเปเบเบเบขเบฒเบเบขเปเบฒเบเปเบเบปเปเบฒเบเบฝเบกเบเบฑเบเปเบเบเบปเปเบงเบเปเปเบเบงเบฒเบก, เปเบฅเบฐเบเบฑเบเบเบฑเบ hash เบเปเปเปเบเปเบฎเบฑเบเบเบฐเบเบฑเบเบเบฒเบเบเบฐเบเบฒเบเบเปเปเบเบงเบฒเบกเบเบตเปเบเบธเบเบเบดเบเปเบฒเบชเปเบฒเบฅเบฑเบเบเบธเบเบเปเบญเบเปเบเบญเบเบเบฐเปเบ.
เบกเบฑเบเปเบเบฑเบเบชเบดเปเบเบชเปเบฒเบเบฑเบเบเบตเปเบเบฐเบชเบฑเบเปเบเบเบงเปเบฒเบขเปเบฒเบเปเบเบเปเปเบเบฒเบกเบเปเบฒเบเปเบฅเบทเบญเบเบเบตเปเบเบฐเปเบเปเบเบเบฑเบเบเปเปเบเบงเบฒเบก, เบเบปเบงเปเบเบเบเบปเบงเบกเบฑเบเปเบญเบเบญเบฒเบเบเบฐเบเปเบญเบเบเบทเบเบเปเบฒเปเบเปเบเบทเบเปเบซเบกเป.
เบเบดเบเบฒเบฅเบฐเบเบฒเบเปเปเบเปเบฒเบเบปเบเบเบตเปเบเบฐเปเบฎเบฑเบเบเปเปเบฒเบเปเปเบกเบนเบเบฅเบฐเบซเบงเปเบฒเบเบเบธเปเบก Kafka เปเบเบชเบฐเบเบฒเบเบเบตเปเบเปเบฒเบเป. เบชเปเบฒเบฅเบฑเบเบเบธเบเบเบฐเบชเบปเบเบเบตเป, Kafka เบกเบฒเบเปเบญเบกเบเบฑเบเปเบเบทเปเบญเบเบกเบทเบเบฑเบเบเบฑเบเบเปเบฒเบชเบฑเปเบเบเบตเปเปเบญเบตเปเบเบงเปเบฒ MirrorMaker, เปเบเบดเปเบเบเบทเบเบเปเบฒเปเบเปเปเบเบทเปเบญเบญเปเบฒเบเบเปเปเบเบงเบฒเบกเบเบฒเบเบเบธเปเบกเบซเบเบถเปเบเปเบฅเบฐเปเบญเบเบเบงเบเบกเบฑเบเปเบเบญเบตเบ.
MirrorMaker เบเปเบญเบเปเบเบปเปเบฒเปเบเบเบฐเปเบเบเบญเบเบซเบปเบงเบเปเปเบเบตเปเปเบฎเบฑเบเบเปเปเบฒเบเบทเบเปเบเบทเปเบญเบฎเบฑเบเบชเบฒเบเบงเบฒเบกเปเบเบฑเบเบฅเบฐเบเบฝเบเบฎเบฝเบเบฎเปเบญเบเบฅเบฐเบซเบงเปเบฒเบเบเปเปเบเบงเบฒเบกเปเบเปเบงเบฅเบฒเบเบตเป replicating เบฅเบฐเบซเบงเปเบฒเบ clusters, เปเบเบทเปเบญเบเบเบฒเบเบงเปเบฒเบเปเบฒเบเบงเบเบเบญเบ partitions เบชเปเบฒเบฅเบฑเบเบซเบปเบงเบเปเปเบเบฑเปเบเบญเบฒเบเบเบฐเบเปเปเบเบทเบเบฑเบเปเบเบชเบญเบ clusters.
เบเบธเบเบเบฐเบชเบฒเบเบเบฒเบเปเบเปเบเบชเปเบงเบเปเบเบเบเบณเบเบปเบเปเบญเบเปเบกเปเบเบเปเบญเบเบเปเบฒเบเบซเบฒเบเบฒเบ, เบเปเบญเบเบงเปเบฒเบเบฒเบเปเบฅเบตเปเบกเบเบปเปเบ hashing เบซเบผเบท round robin เปเบฎเบฑเบเบงเบฝเบเปเบเปเบเบตเปเบเบชเบฐเบเบฒเบเบฐเบเบฒเบเบชเปเบงเบเปเบซเบเป. เบขเปเบฒเบเปเบเบเปเบเบฒเบก, เบเปเบฒเบเปเบฒเบเบเปเบญเบเบเบฒเบเบเบฒเบเบฎเบฑเบเบเบฐเบเบฑเบเบเบฒเบเบชเบฑเปเบเบเบทเปเบเบตเปเปเบเบฑเปเบกเปเบเบเบซเบผเบทเบเปเบญเบเบเบฒเบเบชเบฐเบเบฑเบ metadata เบเบฒเบ payloads, เบซเบผเบฑเบเบเบฒเบเบเบฑเปเบเบเบฒเบเปเบเปเบเบชเปเบงเบเปเบกเปเบเบเบฒเบเบชเบดเปเบเบเบฒเบเบขเปเบฒเบเบเบตเปเบเปเบฒเบเบเบงเบเบเบดเบเบฒเบฅเบฐเบเบฒเบขเปเบฒเบเปเบเปเบเบดเบ.
เบเบปเบเบเบฐเปเบซเบเบเบเปเบฒเบเบเบฒเบเบเบฐเบซเบเบฒเบเปเบฅเบฐเบเบฒเบเบเบฐเบเบดเบเบฑเบเบเบญเบ Kafka เปเบกเปเบเบกเบฒเบเบฒเบเบเบฒเบเบเปเบฝเบเบเบงเบฒเบกเบฎเบฑเบเบเบดเบเบเบญเบเบเบญเบเบเบฒเบเบซเบเปเบฒเบเบทเปเบเปเบกเบทเบญเบเปเบซเปเบเบฑเบเบฅเบนเบเบเปเบฒ. เปเบเบเปเบฅเบฐเบเบตเบเบตเป, เบเบฒเบเบเบฑเบเบชเบดเบเปเบเปเบกเปเบเปเบฎเบฑเบเปเบเบทเปเบญเปเบเบเบขเบฒเบเบเปเปเบเบงเบฒเบกเบเบตเปเบเปเบฝเบงเบเปเบญเบเบฅเบฐเบซเบงเปเบฒเบเบเบนเปเบเปเบฅเบดเปเบเบเบเปเบฒเบเบงเบเบซเบเบถเปเบเบเบตเปเปเบฎเบฑเบเบงเบฝเบเบเบฐเบซเบเบฒเบ.
เบเบฒเบเบซเบเปเบฒ JMS เบเบฑเบเบเปเบฒเปเบเบฑเบเบเปเบญเบเบเบฑเบเบเบฒเบเบเบฑเบเบเบงเบฒเบกเบเปเบญเบเบเบฒเบเบเบฑเปเบเบเปเบฒเบง. เบซเบเปเบฒเบชเบปเบเปเบ, เบเบปเบเปเบเบเบฒเบเบชเบปเปเบเบเปเปเบเบงเบฒเบกเบเบตเปเบเปเบฝเบงเบเปเบญเบเบเบฑเบเบเบนเปเบเปเบฅเบดเปเบเบเบเบฝเบงเบเบฑเบ, เบเบฐเบเบดเบเบฑเบเบเปเบฒเบ JMS Message Groups (เบเบฒเบเบเปเบฝเบเปเบเบเบเบธเบเบเบฐเบชเบฒเบเบเบฒเบเบเบธเปเบเบเปเบฝเบเบเบฒเบเปเบซเบผเบเบซเบเบฝเบง (SLB)), เบเบฑเบเบฎเบฝเบเบฎเปเบญเบเปเบซเปเบเบนเปเบชเบปเปเบเบซเบกเบฒเบเบเปเปเบเบงเบฒเบกเบเบตเปเบเปเบฝเบงเบเปเบญเบ. เปเบเบเปเบฅเบฐเบเบตเบเบญเบ JMS, เบเบฒเบเบซเบเปเบฒเปเบกเปเบเบฎเบฑเบเบเบดเบเบเบญเบเบชเปเบฒเบฅเบฑเบเบเบฒเบเบชเบปเปเบเบเปเปเบเบงเบฒเบกเบเบตเปเบเปเบฝเบงเบเปเบญเบเบเบญเบเบเบธเปเบกเบเบตเปเปเบเบซเบฒเบเบนเปเบเปเบฅเบดเปเบเบเบซเบเบถเปเบเบเบฒเบเบซเบผเบฒเบเปเบเบปเบ, เปเบฅเบฐเบเบฒเบเปเบญเบเบเบงเบฒเบกเปเบเบฑเบเปเบเบปเปเบฒเบเบญเบเบเบธเปเบกเบเปเบฒเบเบนเปเบเปเบฅเบดเปเบเบเบฅเบปเปเบกเบฅเบปเบ.
เบชเบฑเบเบเบฒเบเบนเปเบเบฐเบฅเบดเบ
เบเบฒเบเปเบเปเบเบชเปเบงเบเบเปเปเปเบกเปเบเบชเบดเปเบเบเบฝเบงเบเบตเปเบเบฐเบเบดเบเบฒเบฅเบฐเบเบฒเปเบเปเบงเบฅเบฒเบชเบปเปเบเบเปเปเบเบงเบฒเบก. เบฅเบญเบเปเบเบดเปเบเบงเบดเบเบตเบเบฒเบ send() เบเบญเบเบเบฑเปเบเบเบนเปเบเบฐเบฅเบดเบเปเบ Java API:
Future < RecordMetadata > send(ProducerRecord < K, V > record);
Future < RecordMetadata > send(ProducerRecord < K, V > record, Callback callback);
เบกเบฑเบเบเบงเบเบเบฐเบชเบฑเบเปเบเบเปเบซเบฑเบเบเบฑเบเบเบตเบงเปเบฒเบเบฑเบเบชเบญเบเบงเบดเบเบตเบเบฒเบเบเบฑเบเบเบทเบเบกเบฒเปเบเบญเบฐเบเบฒเบเบปเบ, เปเบเบดเปเบเบเบตเปเปเบซเปเปเบซเบฑเบเบงเปเบฒเบเบฒเบเบเบฐเบเบดเบเบฑเบเบเบฒเบเบชเบปเปเบเบเปเปเปเบเปเบเบทเบเบเบฐเบเบดเบเบฑเบเบเบฑเบเบเบต. เบเบปเบเปเบเปเบฎเบฑเบเปเบกเปเบเบงเปเบฒเบเปเปเบเบงเบฒเบก (ProducerRecord) เปเบเปเบเบทเบเบเบฝเบเปเบเบซเบฒเบชเบปเปเบ buffer เบชเปเบฒเบฅเบฑเบเปเบเปเบฅเบฐเบชเปเบงเบเบเบตเปเบซเปเบฒเบงเบซเบฑเบเปเบฅเบฐเบเบทเบเบชเบปเปเบเปเบเบซเบฒเบเบฒเบเบซเบเปเบฒเปเบเบฑเบเบซเบปเบงเบเปเปเบเบทเปเบเบเบฒเบเปเบเบซเปเบญเบเบชเบฐเบซเบกเบธเบเบฅเบนเบเบเปเบฒ Kafka. เปเบเบเบฐเบเบฐเบเบตเปเบเบตเปเปเบฎเบฑเบเปเบซเปเบชเบดเปเบเบเปเบฒเบเปเปเบงเบขเปเบฒเบเบเปเปเบซเบเปเบฒเปเบเบทเปเบญ, เบกเบฑเบเบซเบกเบฒเบเบเบงเบฒเบกเบงเปเบฒเบเปเบฒเบฎเปเบญเบเบชเบฐเบซเบกเบฑเบเบเบตเปเบเปเปเบกเบตเบเบฐเบชเบปเบเบเบฒเบเบชเบฒเบกเบฒเบเบชเบนเบเปเบชเบเบเปเปเบเบงเบฒเบกเบเปเบฒเบเบฐเบเบงเบเบเบฒเบเบเบญเบเบกเบฑเบเบขเบธเบเปเบเบปเบฒ.
เปเบเบเบฒเบเบฐเปเบเบฑเบเบชเบฐเปเบซเบกเบต, เบกเบตเบงเบดเบเบตเบเบตเปเบเบฐเปเบฎเบฑเบเปเบซเปเบเบฒเบเบเบฐเบเบดเบเบฑเบเบเบฒเบเบชเบปเปเบเบเบตเปเปเบเบทเปเบญเบเบทเปเบเปเบซเบผเบฒเบเบเบถเปเบเปเบเบเปเบฒเปเบเปเบเปเบฒเบเบเบญเบเบเบฒเบเบเบฐเบเบดเบเบฑเบ. เบเบฐเบซเบเบฒเบเบเบญเบ buffer เบเบตเปเบชเบฒเบกเบฒเบเบเบทเบเบเปเบฒเบเบปเบเปเบเบฑเบ 0, เปเบฅเบฐเบเบฐเบเบนเปเบเปเบฒเบฎเปเบญเบเบชเบฐเบซเบกเบฑเบเบเบตเปเบชเบปเปเบเบเบฐเบเบทเบเบเบฑเบเบเบฑเบเปเบซเปเบฅเปเบเปเบฒเบเบปเบเบเปเบงเบฒเบเบฒเบเปเบญเบเบเปเปเบเบงเบฒเบกเปเบเบซเบฒเบเบฒเบเบซเบเปเบฒเปเบกเปเบเบชเปเบฒเปเบฅเบฑเบ, เบเบฑเปเบเบเปเปเปเบเบเบตเป:
RecordMetadata metadata = producer.send(record).get();
เปเบเบตเปเบกเปเบเบตเบกเบเปเบฝเบงเบเบฑเบเบเบฒเบเบญเปเบฒเบเบเปเปเบเบงเบฒเบก
เบเบฒเบเบญเปเบฒเบเบเปเปเบเบงเบฒเบกเบกเบตเบเบงเบฒเบกเบชเบฑเบเบชเบปเบเปเบเบตเปเบกเปเบเบตเบกเบเบตเปเบเปเบญเบเปเบเปเบฎเบฑเบเบเบฒเบเบเบฒเบเบเบฐเปเบเบเปเบฝเบงเบเบฑเบ. เบเปเปเปเบซเบกเบทเบญเบเบเบฑเบ JMS API, เปเบเบดเปเบเบชเบฒเบกเบฒเบเปเบญเบตเปเบเปเบเปเบเบปเบงเบเบฑเบเบเปเปเบเบงเบฒเบกเปเบเบทเปเบญเบเบญเบเบชเบฐเบซเบเบญเบเบเปเปเบเบงเบฒเบก, เบเบนเปเบเปเบฅเบดเปเบเบ Kafka เบเบฝเบเปเบเปเบชเปเบฒเบซเบผเบงเบ. เบเปเปเบซเปเบเบดเบเบฒเบฅเบฐเบเบฒเบงเบดเบเบตเบเบฒเบเบเบตเปเปเบเปเบเบดเบ เปเบเบเบชเบณเบซเบผเบงเบ()เปเบเปเปเบเบทเปเบญเบเบธเบเบเบฐเบชเบปเบเบเบตเป:
ConsumerRecords < K, V > poll(long timeout);
เบเปเบฒเบเบฑเบเบเบทเบเบเบญเบเบงเบดเบเบตเบเบฒเบเปเบกเปเบเปเบเบเบชเปเบฒเบเบเบฑเบเบเบธเบเบตเปเบเบฐเบเบญเบเบเปเบงเบเบงเบฑเบเบเบธเบซเบผเบฒเบเบญเบฑเบ เบเบฑเบเบเบถเบเบเบนเปเบเปเบฅเบดเปเบเบ เบเบฒเบโเบเบฒเบโเปเบเปเบโเบเบฑเบโเบเบตเปโเปเบเบฑเบโเปเบโเปเบเปโเบซเบผเบฒเบโ. เบเบฑเบเบเบถเบเบเบนเปเบเปเบฅเบดเปเบเบ เบเบปเบงเบเบญเบเบกเบฑเบเปเบญเบเปเบเบฑเบเบงเบฑเบเบเบธเบเบตเปเบเบทเบชเปเบฒเบฅเบฑเบเบเบนเปเบเบตเปเบชเปเบฒเบเบฑเบเบเบตเปเบกเบต metadata เบเบตเปเบเปเบฝเบงเบเปเบญเบ, เปเบเบฑเปเบ: เบเบฒเบเปเบเปเบเบเบฑเบเบเบตเปเบกเบฒเบเบฒเบ.
เบเบฑเปเบเบเบตเปเปเบเปเบชเบปเบเบเบฐเบเบฒเปเบเบเบปเบเบเบต 2, เบเบงเบเปเบฎเบปเบฒเบเปเบญเบเบเบทเปเปเบงเปเบงเปเบฒเบกเบตเบซเบเบฑเบเปเบเบตเบเบเบทเปเบเบเบฑเบเบเปเปเบเบงเบฒเบกเบซเบผเบฑเบเบเบฒเบเบเบตเปเบเบงเบเบกเบฑเบเปเบเปเบฎเบฑเบเบเบฒเบเบเบธเบเปเบเปเบเบขเปเบฒเบเบชเปเบฒเปเบฅเบฑเบเบเบปเบเบซเบผเบทเบเปเปเบชเปเบฒเปเบฅเบฑเบ, เบเบปเบงเบขเปเบฒเบเปเบเบฑเปเบเบเปเบฒเบฅเบนเบเบเปเบฒเบเปเปเบชเบฒเบกเบฒเบเบเบฐเบกเบงเบเบเบปเบเบเปเปเบเบงเบฒเบกเปเบเปเบซเบผเบทเบเปเบฒเบกเบฑเบเปเบญเบปเบฒเบฅเบนเบเบญเบญเบ. เปเบ JMS, เบเบตเปเบเบทเบเบเบฑเบเบเบฒเบเปเบเบเบเปเบฒเบเบฎเบนเบเปเบเบเบเบฒเบเบฎเบฑเบเบฎเบนเป. เบเบฒเบเปเปเบฒเบเบฐเบฅเบถเบเบเปเปเบเบงเบฒเบกเบเบตเปเบเบฐเบกเบงเบเบเบปเบเบชเบณเปเบฅเบฑเบเปเบฅเปเบง, เบซเบผเบทเบชเบปเปเบเบเบทเบเบเปเปเบเบงเบฒเบกเบเบดเบ เบซเบผเบทเบเบญเบก (เบชเบปเบกเบกเบธเบเบงเปเบฒเบเบธเบฅเบฐเบเบณเบเบทเบเปเบเป).
Kafka เปเบฎเบฑเบเบงเบฝเบเปเบเบเบเปเบฒเบเบเบฑเบเบซเบผเบฒเบ. เบเปเปเบเบงเบฒเบกเบเปเปเปเบเปเบเบทเบเบฅเบถเบเบฅเปเบฒเบเบขเบนเปเปเบเบเบฒเบเบซเบเปเบฒเบซเบผเบฑเบเบเบฒเบเบเบฒเบเบญเปเบฒเบเบซเบผเบฑเบเบเบฒเบเบชเบฐเปเบเบ, เปเบฅเบฐเบชเบดเปเบเบเบตเปเปเบเบตเบเบเบทเปเบเบเบฑเบเบเบงเบฒเบกเบฅเบปเปเบกเปเบซเบฅเบงเปเบกเปเบเบเบงเบฒเบกเบฎเบฑเบเบเบดเบเบเบญเบเบเบญเบเบฅเบฐเบซเบฑเบเบเบฒเบเบญเปเบฒเบเบเบปเบงเบกเบฑเบเปเบญเบ.
เบเบฑเปเบเบเบตเปเบเบงเบเปเบฎเบปเบฒเปเบเปเบเปเบฒเบง, เบเบธเปเบกเบเบนเปเบเปเบฅเบดเปเบเบเปเบกเปเบเบเปเบฝเบงเบเปเบญเบเบเบฑเบเบเบฒเบเบเบปเบเปเบเบตเบเปเบเบเบฑเบเบเบถเบ. เบเปเบฒเปเบซเบเปเบเบเบฑเบเบเบถเบเบเบตเปเบเปเบฝเบงเบเปเบญเบเบเบฑเบเบเบฒเบเบเบปเบเปเบเบตเบเบเบตเปเบเบปเบเบเบฑเบเบเปเปเบเบงเบฒเบกเบเปเปเปเบเบเบตเปเบเบฐเบญเบญเบเปเบเบเบฒเบเบเบญเบเบชเบฐเบซเบเบญเบ เปเบเบเบชเบณเบซเบผเบงเบ(). เบเบธเบเปเบเปเบงเบฅเบฒเบเบตเปเบเบฒเบเบเบปเบเปเบเบตเบเบเบตเปเปเบเบตเปเบกเบเบถเปเบเปเบกเปเบเบเบฒเบเบเบฑเบเบชเบดเบเปเบเบชเปเบฒเบฅเบฑเบเบเบฒเบเบญเปเบฒเบ.
เบเบฑเบเบเบทเบเปเบเบซเบฒเบฎเบนเบเปเบเบเบเบฒเบเบญเปเบฒเบเบเบตเปเปเบเปเบชเบปเบเบเบฐเบเบฒเบเปเบญเบเบซเบเปเบฒเบเบตเป, เบเบฒเบเบเบธเบเปเบเปเบเบเปเปเบเบงเบฒเบกเบเบฐเบเบญเบเบเปเบงเบเบชเบฒเบกเบเบฑเปเบเบเบญเบ:
- เบเบถเบโเบเปเปโเบเบงเบฒเบกโเบชเปเบฒโเบฅเบฑเบโเบเบฒเบโเบญเปเบฒเบโ.
- เบเบฐเบกเบงเบเบเบปเบเบเปเปเบเบงเบฒเบก.
- เบขเบทเบเบขเบฑเบเบเปเปเบเบงเบฒเบก.
เบเบนเปเบเปเบฅเบดเปเบเบ Kafka เบกเบฒเบเปเบญเบกเบเบฑเบเบเบปเบงเปเบฅเบทเบญเบเบเบฒเบเบเบฑเปเบเบเปเบฒ enable.auto.commit. เบเบตเปเปเบกเปเบเบเบฒเบเบเบฑเปเบเบเปเบฒเปเบฅเบตเปเบกเบเบปเปเบเบเบตเปเปเบเปเปเบฅเบทเปเบญเบเป, เปเบเบฑเปเบเบเบฝเบงเบเบฑเบเบเบฑเบเบเบฒเบเบเบฑเปเบเบเปเบฒเบเบตเปเบกเบตเบเปเบฒเบงเปเบฒ "เบญเบฑเบเบเบฐเปเบเบกเบฑเบ".
เบเปเบญเบ Kafka 0.10, เบฅเบนเบเบเปเบฒเบเบตเปเปเบเปเบเบปเบงเปเบฅเบทเบญเบเบเบตเปเบเบฐเบชเบปเปเบเบเปเบฒเบเบปเบเปเบเบตเบเบเบญเบเบเปเปเบเบงเบฒเบกเบชเบธเบเบเปเบฒเบเบเบตเปเบญเปเบฒเบเบขเบนเปเปเบเบเบฒเบเปเบเบเบฑเปเบเบเปเปเปเบ. เปเบเบเบชเบณเบซเบผเบงเบ() เบซเบผเบฑเบโเบเบฒเบโเบเบฒเบโเบเบธเบโเปเบเปเบโ. เบเบตเป เปเบฒเบ เบเบงเบฒเบกเบงเปเบฒเบเปเปเบเบงเบฒเบกเปเบ เปเบถเปเบ เบเบตเปเบเบทเบเบเบถเบเบกเบฒเปเบฅเปเบงเบชเบฒเบกเบฒเบเบเบทเบเบเบฐเบกเบงเบเบเบปเบเบเบทเบ เปเปเป เบเปเบฒเบฅเบนเบเบเปเบฒเปเบเปเบเบฐเบกเบงเบเบเบปเบเบเบงเบเบกเบฑเบเปเบฅเปเบงเปเบเปเบเบทเบ เบเบณ เบฅเบฒเบเปเบเบเบเปเปเบเบฒเบเบเบดเบเบเปเบญเบเบเบตเปเบเบฐเปเบเบซเบฒ. เปเบเบเบชเบณเบซเบผเบงเบ(). เปเบเบทเปเบญเบเบเบฒเบเบเบฒเบเบซเบเปเบฒเบเปเปเปเบเปเบฎเบฑเบเบชเบฒเบฅเบฑเบเปเบเปเบเปเบฝเบงเบเบฑเบเบเปเบฒเบเบงเบเบเปเปเบเบงเบฒเบกเบเบตเปเบเบทเบเบญเปเบฒเบ, เบเบนเปเบเปเบฅเบดเปเบเบเบเปเปเปเบเบเบตเปเบเบถเบเบเปเปเบเบงเบฒเบกเบเบฑเปเบเบเบฐเบเปเปเบฎเบนเปเบงเปเบฒเบชเบดเปเบเบเบตเปเบเปเปเบเบตเปเบเปเปเบเบตเบเบเบถเปเบ. เบเบถเบเบเบดเบเปเบฒเบเบตเปเปเบกเปเบเบเบฒเบเปเบฎเบฑเบเบเบธเบฅเบฐเบเปเบฒ pseudo. เบเบฒเบเบเบปเบเปเบเบตเบเปเบกเปเบเบชเบฑเบเบเบฒเบเบฝเบเปเบเปเบเปเบฒเบเปเปเบเบงเบฒเบกเบเบทเบเบเบฐเบเบดเบเบฑเบเบขเปเบฒเบเบชเปเบฒเปเบฅเบฑเบเบเบปเบ, เปเบเปเบเปเบฒเบฅเบนเบเบเปเบฒเบเบปเบเปเบฅเบตเบ, เบเบฒเบเบซเบเปเบฒเบเบฐเบชเบปเปเบเบเปเปเบเบงเบฒเบกเบเบฝเบงเบเบฑเบเบเบฑเบเบฅเบนเบเบเปเบฒเบญเบทเปเบ. เบเบถเบเบเบดเบเปเบฒเบเบตเปเปเบกเปเบเบชเบญเบเบเปเบญเบเบเบฑเบเบเบฒเบเบฎเบฑเบเบเบฐเบเบฑเบเบเบฒเบเบชเบปเปเบเบเปเปเบเบงเบฒเบก "เบขเปเบฒเบเบซเบเปเบญเบเบซเบเบถเปเบเบเบฑเปเบ"
เปเบ Kafka 0.10, เบฅเบฐเบซเบฑเบเบฅเบนเบเบเปเบฒเปเบเปเบเบทเบเบเปเบฝเบเปเบเบเปเบเบทเปเบญเปเบซเปเบเปเบฒเบซเบกเบฑเปเบเบชเบฑเบเบเบฒเบเบทเบเบเบฐเบเบธเปเบเปเบเบฑเบเปเบเปเบฅเบฐเปเบฅเบเบฐเปเบเบเบซเปเบญเบเบชเบฐเบซเบกเบธเบเบฅเบนเบเบเปเบฒ, เบเบฒเบกเบเบตเปเปเบเปเบเปเบฒเบเบปเบเปเบงเป. auto.commit.interval.ms. เบเบถเบเบเบดเบเปเบฒเบเบตเปเปเบกเปเบเบขเบนเปเบเปเบญเบเปเบเบเปเบญเบเปเบถเปเบเบฅเบฐเบซเบงเปเบฒเบเปเปเบ JMS AUTO_ACKNOWLEDGE เปเบฅเบฐ DUPS_OK_ACKNOWLEDGE. เปเบกเบทเปเบญเบเปเบฒเปเบเป autocommit, เบเปเปเบเบงเบฒเบกเบชเบฒเบกเบฒเบเบเบทเบเบชเบฑเบเบเบฒเปเบเบเบเปเปเบเปเบฒเบเบถเบเปเบเบดเบเบงเปเบฒเบเบงเบเบกเบฑเบเบเบทเบเบเบธเบเปเบเปเบเบขเปเบฒเบเปเบเปเบเบดเบ - เบเบตเปเบชเบฒเบกเบฒเบเปเบเบตเบเบเบทเปเบเปเบเบเปเบฅเบฐเบเบตเบเบญเบเบเบนเปเบเปเบฅเบดเปเบเบเบเปเบฒ. เบเปเบฒเบเบนเปเบเปเบฅเบดเปเบเบเบเบปเบเปเบฅเบตเบ, เบเปเปเบเบงเบฒเบกเบเบฐเบเบทเบเบเบถเบเบกเบฒเปเบเบเบเบนเปเบเปเบฅเบดเปเบเบเบเปเปเปเบ, เปเบฅเบตเปเบกเบเบปเปเบเบเบฒเบเบเปเบฒเปเบซเบเปเบเบเบตเปเบซเบกเบฑเปเบเบชเบฑเบเบเบฒ, เปเบเบดเปเบเบญเบฒเบเบเบฐเปเบฎเบฑเบเปเบซเปเบเปเปเบเบงเบฒเบกเบเบฒเบเปเบญเบเบฒเบ. เปเบเบเปเบฅเบฐเบเบตเบเบตเป, Kafka เบเปเปเปเบเปเบชเบนเบเปเบชเบเบเปเปเบเบงเบฒเบก, เบฅเบฐเบซเบฑเบเบเบฒเบเบญเปเบฒเบเบเบฝเบเปเบเปเบเปเปเปเบเปเบเบฐเบกเบงเบเบเบปเบเบเบงเบเบกเบฑเบ.
เปเบซเบกเบเบเบตเปเบกเบตเบเปเบฒเบชเบฑเบเบเบฒเบเบฝเบงเบเบฑเบเบเบฑเบเบชเบฐเบเบฑเบ 0.9: เบเปเปเบเบงเบฒเบกเบชเบฒเบกเบฒเบเบเปเบฒเปเบเบตเบเบเบฒเบเปเบเป, เปเบเปเบเปเบฒเบกเบฑเบเบฅเบปเปเบกเปเบซเบฅเบง, เบเบฒเบเบเบปเบเปเบเบตเบเบญเบฒเบเบเบฐเบเปเปเบซเบกเบฑเปเบเบชเบฑเบเบเบฒ, เบญเบฒเบเบเบฐเปเบฎเบฑเบเปเบซเปเบเบฒเบเบเบฑเบเบชเบปเปเบเปเบเบตเปเบกเบเบถเปเบเบชเบญเบเปเบเบปเปเบฒ. เบเปเปเบเบงเบฒเบกเบเบตเปเปเบเบปเปเบฒเบเบถเบเบกเบฒเปเบเปเบซเบผเบฒเบเบเบถเปเบเปเบกเบทเปเบญเบเบณเปเบเบตเบเบเบฒเบ เปเบเบเบชเบณเบซเบผเบงเบ(), เบเบฑเบเบซเบฒเบเบตเปเบซเบผเบฒเบ.
เบเบฑเปเบเบเบตเปเปเบเปเบชเบปเบเบเบฐเบเบฒเปเบ "เบเบฒเบเบญเปเบฒเบเบเปเปเบเบงเบฒเบกเบเบฒเบเปเบเบง" เปเบเบซเบเปเบฒ 21, เบเปเปเบกเบตเบชเบดเปเบเบเบฑเปเบเบเปเบฒเบงเปเบเบฑเบเบเบฒเบเบชเบปเปเบเบเปเปเบเบงเบฒเบกเบเบฑเปเบเบเบฝเบงเปเบเบฅเบฐเบเบปเบเบเบฒเบเบชเบปเปเบเบเปเปเบเบงเบฒเบกเปเบเปเบงเบฅเบฒเบเบตเปเบฎเบนเบเปเบเบเบเบงเบฒเบกเบฅเบปเปเบกเปเบซเบฅเบงเบเบทเบเบเบดเบเบฒเบฅเบฐเบเบฒ.
เปเบ Kafka, เบกเบตเบชเบญเบเบงเบดเบเบตเบเบตเปเบเบฐ commit (เบเปเบฒเบซเบกเบฑเปเบเบชเบฑเบเบเบฒ) offset (offset): เบญเบฑเบเบเบฐเปเบเบกเบฑเบเปเบฅเบฐเบเบนเปเบกเบท. เปเบเบเบฑเบเบชเบญเบเบเปเบฅเบฐเบเบต, เบเปเปเบเบงเบฒเบกเบชเบฒเบกเบฒเบเบเบทเบเบเบฐเบกเบงเบเบเบปเบเบซเบผเบฒเบเบเบฑเปเบเบเปเบฒเบเปเปเบเบงเบฒเบกเบเบทเบเบเบฐเบกเบงเบเบเบปเบเปเบเปเบฅเบปเปเบกเปเบซเบฅเบงเบเปเบญเบเบเปเบฒเบซเบกเบฑเปเบเบชเบฑเบเบเบฒ. เบเบญเบเบเบฑเปเบเบเปเบฒเบเบเบฑเบเบชเบฒเบกเบฒเบเปเบฅเบทเบญเบเบเบตเปเบเบฐเบเปเปเบเปเบฒเปเบเบตเบเบเบฒเบเบเปเปเบเบงเบฒเบกเบเบฑเบเบซเบกเบปเบเบเปเบฒเบซเบฒเบเบงเปเบฒเบเปเบฒเบซเบกเบฑเปเบเบชเบฑเบเบเบฒเปเบเบตเบเบเบถเปเบเปเบเบเบทเปเบเบซเบฅเบฑเบเปเบฅเบฐเบฅเบฐเบซเบฑเบเบเบญเบเบเปเบฒเบเปเบเปเบเบทเบเบชเปเบฒเปเบฅเบฑเบเบเปเบญเบเบเบตเปเบเบฐเบชเบฒเบกเบฒเบเบเปเบฒเปเบเบตเบเบเบฒเบเปเบเป (เบเบฒเบเบเบตเบญเบฒเบเบกเบตเบขเบนเปเปเบ Kafka 0.9 เปเบฅเบฐเบเปเบญเบเบซเบเปเบฒเบเบฑเปเบ).
เบเปเบฒเบโเบชเบฒโเบกเบฒเบโเบเบงเบโเบเบธเบกโเบเบฐโเบเบงเบโเบเบฒเบ offset commit เบเบนเปโเบกเบทโเปเบ Kafka consumer API เปเบเบโเบเบฒเบโเบเบฑเปเบโเบเปเบฒโเบเบฒโเบฅเบฒโเบกเบดโเปเบเบตโ enable.auto.commit เบเบดเบ เปเบฅเบฐ เปเบเบซเบฒเบขเปเบฒเบเบเบฐเปเบเปเบเบงเบดเบเบตเปเบถเปเบเบเปเปเปเบเบเบตเป:
void commitSync();
void commitAsync();
เบเปเบฒเบเปเบฒเบเบเปเบญเบเบเบฒเบเบเบฐเบกเบงเบเบเบปเบเบเปเปเบเบงเบฒเบก "เบขเปเบฒเบเบซเบเปเบญเบเบซเบเบถเปเบเบเบฑเปเบ", เบเปเบฒเบเบเปเบญเบเบเบฐเบเบดเบเบฑเบเบเบฒเบเบเบปเบเปเบเบตเบเบเปเบงเบเบเบปเบเปเบญเบ commitSync()เปเบเบเบเบฒเบเบเบฐเบเบดเบเบฑเบเบเปเบฒเบชเบฑเปเบเบเบตเปเบเบฑเบเบเบตเบซเบผเบฑเบเบเบฒเบเบเบฒเบเบเบฐเบกเบงเบเบเบปเบเบเปเปเบเบงเบฒเบก.
เบงเบดเบเบตเบเบฒเบเปเบซเบผเบปเปเบฒเบเบตเปเบเปเปเบญเบฐเบเบธเบเบฒเบเปเบซเปเบเปเปเบเบงเบฒเบกเปเบเปเบฎเบฑเบเบเบฒเบเบเบญเบกเบฎเบฑเบเบเปเบญเบเบเบตเปเบเบฐเบเปเบฒเปเบเบตเบเบเบฒเบ, เปเบเปเบเบงเบเปเบเบปเบฒเบเปเปเปเบเปเปเบฎเบฑเบเบซเบเบฑเบเปเบเบทเปเบญเบฅเบปเบเบฅเปเบฒเบเบเบงเบฒเบกเบฅเปเบฒเบเปเบฒเปเบเบเบฒเบเบเบธเบเปเบเปเบเปเบเบเบฐเบเบฐเบเบตเปเปเบซเปเบฎเบนเบเบฅเบฑเบเบชเบฐเบเบฐเบเบญเบเบเบฒเบเปเบฎเบฑเบเบเบธเบฅเบฐเบเปเบฒ. เบเปเปเบกเบตเบเบธเบฅเบฐเบเปเบฒเปเบ Kafka. เบฅเบนเบเบเปเบฒเบเปเปเบกเบตเบเบงเบฒเบกเบชเบฒเบกเบฒเบเปเบเบเบฒเบเปเบฎเบฑเบเบชเบดเปเบเบเปเปเปเบเบเบตเป:
- เบกเปเบงเบเบเบทเบเบเปเปเบเบงเบฒเบกเบเบตเปเบเบทเบเบเบญเบกเปเบเบเปเบเบเบญเบฑเบเบเบฐเปเบเบกเบฑเบ. เบเบนเปเบเปเบฅเบดเปเบเบเปเบญเบเบเปเบญเบเบเบฑเบเบเบฒเบเบเบฑเบเบเปเปเบเบปเบเปเบงเบฑเปเบเบเบตเปเปเบเบตเบเบเบฒเบเบเบฒเบเปเบซเบผเบเบเบตเปเบกเบตเบเบฑเบเบซเบฒเปเบฅเบฐ backend outages, เบเปเบญเบเบงเปเบฒเบเบงเบเปเบเบปเบฒเบเปเปเบชเบฒเบกเบฒเบเบญเบตเบเปเบชเปเบเบฒเบเบซเบเปเบฒเปเบเบทเปเบญเบชเบปเปเบเบเบทเบเบเปเปเบเบงเบฒเบก.
- เบชเบปเปเบเบเปเปเบเบงเบฒเบกเปเบเบซเบฒเบซเบผเบฒเบเบซเบปเบงเบเปเปเปเบเบเบฒเบเบเบฐเบเบดเบเบฑเบเบเบฐเบฅเปเบฒเบกเบฐเบเบนเบซเบเบถเปเบ. เบเบฑเปเบเบเบตเปเบเบงเบเปเบฎเบปเบฒเบเบฐเปเบซเบฑเบเปเบเปเบงเปเบเบตเป, เบเบฒเบเบเบงเบเบเบธเบกเบซเบปเบงเบเปเปเบเบตเปเปเบเบเบเปเบฒเบเบเบฑเบเปเบฅเบฐเบเบฒเบเปเบเปเบเบเบฑเบเบชเบฒเบกเบฒเบเบญเบฒเปเบชเบขเบนเปเปเบเปเบเบทเปเบญเบเบเบฑเบเบเบตเปเปเบเบเบเปเบฒเบเบเบฑเบเปเบเบเบธเปเบก Kafka เบเบตเปเบเปเปเบเบฐเบชเบฒเบเบเบฒเบเบเบฒเบเปเบฎเบฑเบเบเบธเบฅเบฐเบเปเบฒเปเบกเบทเปเบญเบชเบปเปเบ. เปเบเปเบงเบฅเบฒเบเบฝเบเบเบตเป, เบเบฒเบเบงเบฝเบเปเบเปเบเบทเบเบเบฐเบเบดเบเบฑเบเปเบเบทเปเบญเปเบฎเบฑเบเปเบซเปเบชเบดเปเบเบเบตเปเปเบเบฑเบเปเบเปเบเปเบเบฑเบ KIP-98.
- เปเบเบทเปเบญเบกเปเบเบเบเบฒเบเบญเปเบฒเบเบเปเปเบเบงเบฒเบกเบซเบเบถเปเบเบเบฒเบเบซเบปเบงเบเปเปเบซเบเบถเปเบเบเบฑเบเบเบฒเบเบชเบปเปเบเบเปเปเบเบงเบฒเบกเบญเบทเปเบเปเบเบซเบฒเบซเบปเบงเบเปเปเบญเบทเปเบ. เบญเบตเบเปเบเบทเปเบญเบซเบเบถเปเบ, เบชเบฐเบเบฒเบเบฑเบเบเบฐเบเบฐเบเปเบฒเบเบญเบ Kafka เปเบกเปเบเบเบถเปเบเบเบฑเบเปเบเบทเปเบญเบเบเบฑเบเปเบญเบเบฐเบฅเบฒเบเบเปเบฒเบเบงเบเบซเบผเบฒเบเบเบตเปเปเบฅเปเบเปเบเบฑเบเบฅเบปเบเปเบกเบซเบเบถเปเบเปเบฅเบฐเบเปเปเบกเบตเบเบฒเบเบเบฐเบเบฒเบเบฒเบกเบเบดเบเบเบฑเบเบชเบดเปเบเบเบตเป. เบเบปเบงเบขเปเบฒเบ, เบเปเปเบกเบตเบญเบปเบเบเบฐเบเบญเบ API เบเบตเปเบญเบฐเบเบธเบเบฒเบเปเบซเปเบเปเบฒเบเปเบเบทเปเบญเบกเบเปเป เบเบนเปเบเปเบฅเบดเปเบเบ ะธ เบเบนเปเบเบฐเบฅเบดเบ เปเบเบเบธเบฅเบฐเบเปเบฒ. เปเบ JMS, เบเบตเปเปเบกเปเบเบชเบฐเบซเบเบญเบเปเบซเปเปเบเบเบงเบฑเบเบเบธ เบเบญเบเบเบฐเบเบธเบกเบเบฒเบเบเบตเปเบเบทเบเบชเปเบฒเบเบเบถเปเบ MessageProducers ะธ MessageConsumers.
เบเปเบฒเบเบงเบเปเบฎเบปเบฒเบเปเปเบชเบฒเบกเบฒเบเบญเบตเบเปเบชเปเบเบฒเบเปเบฎเบฑเบเบเบธเบฅเบฐเบเปเบฒ, เบเบงเบเปเบฎเบปเบฒเบชเบฒเบกเบฒเบเบชเบฐเบซเบเบญเบเบเบงเบฒเบกเบซเบกเบฒเบเบเบตเปเปเบเปเบเบดเบเบเบฑเบเบชเบดเปเบเบเบตเปเบชเบฐเบซเบเบญเบเปเบเบเบฅเบฐเบเบปเบเบเบฒเบเบชเบปเปเบเบเปเปเบเบงเบฒเบกเปเบเบเบเบฑเปเบเปเบเบตเบกเปเบเปเปเบเบงเปเบ?
เบเปเบฒเบกเบตเบเบงเบฒเบกเปเบเบฑเบเปเบเปเบเปเบเบตเปเบเบฒเบเบเบปเบเปเบเบตเบเบเบญเบเบเบนเปเบเปเบฅเบดเปเบเบเบญเบฒเบเบเบฐเปเบเบตเปเบกเบเบถเปเบเบเปเบญเบเบเบตเปเบเปเปเบเบงเบฒเบกเปเบเปเบเบทเบเบเบธเบเปเบเปเบ, เปเบเบฑเปเบ: เปเบเบฅเบฐเบซเบงเปเบฒเบเบญเบธเบเบฐเบเบดเปเบซเบเบเบญเบเบเบนเปเบเปเบฅเบดเปเบเบ, เบซเบผเบฑเบเบเบฒเบเบเบฑเปเบเบเบนเปเบเปเบฅเบดเปเบเบเบเปเปเบกเบตเบเบฒเบเบเบตเปเบเบฐเบฎเบนเปเบงเปเบฒเบเบธเปเบกเบเบนเปเบเปเบฅเบดเปเบเบเบเบญเบเบเบปเบเบเบฒเบเบเปเปเบเบงเบฒเบกเปเบเปเบงเบฅเบฒเบเบตเปเบกเบฑเบเบเบทเบเบกเบญเบเบซเบกเบฒเบเบเบฒเบเบดเบเบฑเบ. เบเบฑเปเบเบเบฑเปเบเบเบธเบเบเบฐเบชเบฒเบเบซเบเบถเปเบเปเบกเปเบเปเบเบทเปเบญ rewind เบเบปเบเปเบเบตเบเบเบฑเบเบเปเบฒเปเบซเบเปเบเบเบตเปเบเปเบฒเบเบกเบฒ. API เบเบนเปเบเปเบฅเบดเปเบเบ Kafka เบชเบฐเบซเบเบญเบเบงเบดเบเบตเบเบฒเบเบเบฑเปเบเบเปเปเปเบเบเบตเปเบชเปเบฒเบฅเบฑเบเบเบฒเบเบเบตเป:
void seek(TopicPartition partition, long offset);
void seekToBeginning(Collection < TopicPartition > partitions);
เบงเบดเบเบตเบเบฒเบ เบเบญเบเบซเบฒ() เบชเบฒเบกเบฒเบเบเปเบฒเปเบเปเบเบฑเบเบงเบดเบเบตเบเบฒเบ
offsetsForTimes(เปเบเบเบเบตเป timestampsToSearch) เปเบเบทเปเบญเบเบฑเบเบเบทเบเบชเบนเปเบชเบฐเบเบฒเบเบฐเปเบเบเบฒเบเบเบธเบเบชเบฐเปเบเบฒเบฐเปเบเบญเบฐเบเบตเบ.
เปเบเบเบเบงเบฒเบกเบซเบกเบฒเบ, เบเบฒเบเบเปเบฒเปเบเปเบงเบดเบเบตเบเบฒเบเบเบตเปเบซเบกเบฒเบเบเบงเบฒเบกเบงเปเบฒเบกเบฑเบเปเบเบฑเบเปเบเปเบเปเบซเบผเบฒเบเบเบตเปเบเบฒเบเบเปเปเบเบงเบฒเบกเบเบตเปเบเบทเบเบเบธเบเปเบเปเบเบเปเบญเบเบซเบเปเบฒเบเบตเปเบเบฐเบเบทเบเบญเปเบฒเบเปเบฅเบฐเบเปเบฒเปเบเบตเบเบเบฒเบเบญเบตเบเปเบเบทเปเบญเบซเบเบถเปเบ. เปเบเบทเปเบญเบซเบผเบตเบเปเบงเบฑเปเบเบเบฒเบเบเบตเป, เบเบงเบเปเบฎเบปเบฒเบชเบฒเบกเบฒเบเบเปเบฒเปเบเปเบเบฒเบเบญเปเบฒเบ idempotent, เบเบฑเปเบเบเบตเปเบญเบฐเบเบดเบเบฒเบเปเบงเปเปเบเบเบปเบเบเบต 4, เปเบเบทเปเบญเบฎเบฑเบเบชเบฒเบเปเปเบเบงเบฒเบกเบเบตเปเปเบเบดเปเบเบเปเบญเบเบซเบเปเบฒเบเบตเปเปเบฅเบฐเบฅเบปเบเบฅเปเบฒเบเบเบฒเบเบเปเปเบฒเบเบฑเบ.
เบญเบตเบเบเบฒเบเปเบฅเบทเบญเบ, เบฅเบฐเบซเบฑเบเบเบนเปเบเปเบฅเบดเปเบเบเบเบญเบเบเปเบฒเบเบชเบฒเบกเบฒเบเบเบทเบเปเบเบฑเบเบฎเบฑเบเบชเบฒเปเบงเปเบเปเบฒเบเบเบฒเบ, เบเบฒเบเปเบเบเบตเปเบเบฒเบเบชเบนเบเปเบชเบเบเปเปเบเบงเบฒเบกเบซเบผเบทเบเบฒเบเบเปเปเบฒเบเปเบญเบเปเบกเปเบเบเบญเบกเบฎเบฑเบเปเบเป. เปเบกเบทเปเบญเบเบงเบเปเบฎเบปเบฒเบเบดเบเบฒเบฅเบฐเบเบฒเบเปเบฅเบฐเบเบตเบเบฒเบเบเปเบฒเปเบเปเบเบตเป Kafka เบเบทเบเบเปเบฒเปเบเปเบเบปเปเบงเปเบ, เปเบเบฑเปเบ: เบเบฒเบเบเบฑเบเบเบฒเบเปเบซเบเบเบฒเบเบเบฑเบเบเบถเบ, เบงเบฑเบเปเบเบ, เบเบฒเบเบเบดเบเบเบฒเบกเบเบฒเบเบเบฅเบดเบ, เปเบฅเบฐเบญเบทเปเบเป, เบเบงเบเปเบฎเบปเบฒเปเบเบปเปเบฒเปเบเบงเปเบฒเบเบฒเบเบชเบนเบเปเบชเบเบเปเปเบเบงเบฒเบกเบชเปเบงเบเบเบธเบเบเบปเบเบเปเปเบซเบเปเบฒเบเบฐเบกเบตเบเบปเบเบเบฐเบเบปเบเบขเปเบฒเบเบซเบผเบงเบเบซเบผเบฒเบเบเปเปเบเปเบฒเบฎเปเบญเบเบชเบฐเบซเบกเบฑเบเบญเปเบญเบกเบเปเบฒเบ. เปเบเบเปเบฅเบฐเบเบตเบเบฑเปเบเบเปเบฒเบง, เบเปเบฒเปเบฅเบตเปเบกเบเบปเปเบเปเบกเปเบเบเบญเบกเบฎเบฑเบเบขเปเบฒเบเบชเบปเบกเบเบนเบ. เปเบเบเบฒเบเบเบปเบเบเบฑเบเบเปเบฒเบก, เบเปเบฒเบเปเบฒเบฎเปเบญเบเบชเบฐเบซเบกเบฑเบเบเบญเบเบเปเบฒเบเบเปเบญเบเบเบฒเบเบชเบปเปเบเปเบเบดเบ, เบเปเบฒเบเบเปเบญเบเปเบเบดเปเบเปเบเบเบเปเปเบเบงเบฒเบกเปเบเปเบฅเบฐเบเบปเบเบขเปเบฒเบเบฅเบฐเบกเบฑเบเบฅเบฐเบงเบฑเบ. เบกเบฑเบเบเบฑเบเบซเบกเบปเบเปเบกเปเบเบกเบฒเบเบฒเบเบชเบฐเบเบฒเบเบเบฒเบ.
เบเบฒเบเบชเบฑเบเปเบเบเบชเปเบงเบเบเบธเบเบเบปเบเบชเบฐเปเบเบเปเบซเปเปเบซเบฑเบเบงเปเบฒเปเบกเบทเปเบญเบเบงเบฒเบกเปเบเบฑเปเบกเบเบปเปเบเบเบญเบเบเปเปเบเบงเบฒเบกเปเบเบตเปเบกเบเบถเปเบ, เบกเบนเบเบเปเบฒเบเบญเบเบเปเปเบเบงเบฒเบกเปเบเปเบฅเบฐเบเบปเบเบซเบผเบธเบเบฅเบปเบ. เบเปเปเบเบงเบฒเบกเบเบฐเบซเบเบฒเบเปเบซเบเปเบกเบตเปเบเบงเปเบเปเบกเบเบตเปเบเบฐเบกเบตเบเบธเบเบเปเบฒเปเบเปเบงเบฅเบฒเบเบตเปเปเบเบดเปเบเปเบเบฎเบนเบเปเบเบเบฅเบงเบก.
เบกเบตเปเบซเปเบชเบนเบ
เบงเบดเบเบตเบเบฒเบเบเบญเบ Kafka เบเบฑเบเบเบงเบฒเบกเบเปเบญเบกเบเบตเปเบชเบนเบเปเบกเปเบเปเบเบเบเปเบฒเบเบเบฑเบเบซเบผเบฒเบเบเบฒเบเบงเบดเบเบตเบเบฒเบเบเบญเบ ActiveMQ. Kafka เบเบทเบเบญเบญเบเปเบเบเบญเปเบญเบกเบเบธเปเบกเบเบธเปเบกเบเบตเปเบกเบตเบเบฐเปเบฒเบเบเบตเปเบเบธเบเบเบปเบงเบขเปเบฒเบเบเบญเบเบเบฒเบเปเปเบฒเปเบเปเบฎเบฑเบ เปเบฅเบฐเปเบเบเบขเบฒเบเบเปเปเบเบงเบฒเบกเปเบเปเบงเบฅเบฒเบเบฝเบงเบเบฑเบ.
เบเบธเปเบก Kafka เบเบฐเบเบญเบเบเปเบงเบเบซเบผเบฒเบเปเบเบปเบงเบขเปเบฒเบเบเบฒเบเบซเบเปเบฒเบเบตเปเปเบฎเบฑเบเบงเบฝเบเบขเบนเปเปเบเปเบเบทเปเบญเบเปเบกเปเบเปเบฒเบเบเบตเปเปเบเบเบเปเบฒเบเบเบฑเบ. Kafka เบเบทเบเบญเบญเบเปเบเบเบกเบฒเปเบเบทเปเบญเปเบฅเปเบเปเบเบฎเบฒเบเปเบงเปเบเบเบเปเบฝเบงเปเบเบเบเบณเบกเบฐเบเบฒ, เบเปเบญเบเบเบตเปเปเบเปเบฅเบฐ node เบกเบตเบเปเบญเบเปเบเบฑเบเบเปเปเบกเบนเบเบชเบฐเปเบเบฒเบฐเบเบญเบเบเบปเบเปเบญเบ. เบเบฒเบโเบเปเบฒโเปเบเปโเบเบฒเบโเปเบเบฑเบโเบฎเบฑเบโเบชเบฒโเบเบดเบโเบเปเปโเปเบเบทเบญโเบเปเบฒเบ (SANโ) เบเปเปโเปเบเปโเปเบเบฐโเบเปเบฒโเปเบเบทเปเบญเบโเบเบฒเบโเบงเปเบฒโเบเปเปโเบกเบนเบโเบเบญเบโเบเบญเบกโเบเบดเบงโเปเบเบตโเบซเบผเบฒเบโเบชเบฒโเบกเบฒเบโเปเบเปเบโเบเบฑเบโเบชเปเบฒโเบฅเบฑเบโเบเบฒเบโเปเบเปโเปเบงโเบฅเบฒโ.ะซe เปเบฅเบเบฐเบเบฒเบเปเบเบฑเบเบฎเบฑเบเบชเบฒเปเบฅเบฐเบชเปเบฒเบเบเบงเบฒเบกเบเบฑเบเปเบเปเบ.
Kafka เปเบกเปเบ เบขเบนเปเบชเบฐเปเปเบต เบฅเบฐเบเบปเบ. เบเบนเปเปเบเป Kafka เบเบฐเบซเบเบฒเบเปเบซเบเปเบเปเบฒเบเบงเบเบซเบผเบฒเบเบเปเปเปเบเบตเบเบเบดเบเบเบธเปเบกเบเบญเบเปเบเบปเบฒเปเบเบปเปเบฒเปเบฅเบฐเบเบญเบเปเบงเบชเบฐเปเบซเบกเบตเบเบฑเบเบเบธเบเบเปเบงเบเบเบฒเบเปเบฅเบตเปเบกเบเบปเปเบเปเบซเบกเปเบเบฒเบกเบฅเปเบฒเบเบฑเบ. เบเบตเปเปเบกเปเบเบเบฑเบเบฅเบธเปเบเปเปเบเบเบเบฒเบเบฎเบฑเบเบเบฐเบเบฑเบเบเบงเบฒเบกเปเบเบปเปเบฒเบเบฑเบเปเบเปเบเบฑเบเบชเบฐเบเบฑเบเบเบตเปเบเปเบฒเบเบกเบฒเบชเปเบฒเบฅเบฑเบเบเปเปเบเบงเบฒเบกเปเบฅเบฐเบเบฒเบเปเบเปเบเบญเบเบฅเบฐเบซเบงเปเบฒเบเบเบฒเบเบซเบเปเบฒ.
เบเบฒเบเปเปเบฒเบเบตเปเปเบเบทเปเบญเบกเบเปเปเบเบฑเบเบเบธเปเบกเปเบเบตเบเปเบงเบต
เปเบเบเปเบฅเบฐเบเบตเบเบทเปเบเบเบฒเบ, เบซเบปเบงเบเปเปเบเบทเบเบชเปเบฒเบเบขเบนเปเปเบเบเบธเปเบก Kafka เบเบตเปเบกเบตเบเบธเบเบชเบปเบกเบเบฑเบเบเบฑเปเบเบเปเปเปเบเบเบตเป:
- เบเปเบฒโเบเบงเบโเบเบญเบโเบเบฒเบโเปเบเปเบโเบเบฑเบโ. เบเบฑเปเบเบเบตเปเปเบเปเบชเบปเบเบเบฐเบเบฒเบเปเบญเบเบซเบเปเบฒเบเบตเป, เบกเบนเบเบเปเบฒเบเบตเปเปเบเปเบเบญเบเบเบตเปเปเบเปเบขเบนเปเบเบตเปเบเบตเปเปเบกเปเบเบเบถเปเบเบเบฑเบเบฅเบฐเบเบฑเบเบเบตเปเบเปเบญเบเบเบฒเบเบเบญเบเบเบฒเบเบญเปเบฒเบเบเบฐเบซเบเบฒเบ.
- เบเบฑเบเปเบเบเบฒเบเบเปเบฒเบฅเบญเบ (เบเบฑเบเปเบ) เบเปเบฒเบเบปเบเบเปเบฒเบเบงเบเบเบปเบงเบขเปเบฒเบเบเบญเบเบเบฒเบเบซเบเปเบฒเปเบเบเบธเปเบกเบเบงเบเบเบฐเบกเบตเบเบฑเบเบเบถเบเบชเปเบฒเบฅเบฑเบเบเบฒเบเบดเบเบฑเบเบเบตเป.
เบเบฒเบเบเปเบฒเปเบเป ZooKeepers เบชเปเบฒเบฅเบฑเบเบเบฒเบเบเบฐเบชเบฒเบเบเบฒเบ, Kafka เบเบฐเบเบฒเบเบฒเบกเบขเปเบฒเบเบเบธเบเบเบดเบเปเบฒเปเบเบทเปเบญเปเบเบเบขเบฒเบเบเบฒเบเปเบเปเบเบชเปเบงเบเปเบซเบกเปเบฅเบฐเบซเบงเปเบฒเบเบเบฒเบเบซเบเปเบฒเปเบเบเบธเปเบก. เบเบตเปเปเบกเปเบเปเบฎเบฑเบเปเบเบเบเบปเบงเบขเปเบฒเบเบเบฝเบงเบเบตเปเปเบฎเบฑเบเบซเบเปเบฒเบเบตเปเปเบเบฑเบเบเบนเปเบเบงเบเบเบธเบก.
เปเบเปเบงเบฅเบฒเปเบฅเปเบ เบชเปเบฒโเบฅเบฑเบโเบเบฒเบโเปเบเปเบโเบเบฑเบโเบซเบปเบงโเบเปเปโเปเบเปโเบฅเบฐโเบเบปเบโ เบเบนเปเบเบงเบเบเบธเบก เบกเบญเบเปเบฒเบเปเปเบฒเบเบตเปเปเบซเปเบเบฒเบเปเปเบฒ เบเบนเปเบเปเบฒ (เบเบนเปเบเปเบฒ, เบเบปเปเบเบชเบฐเบเบฑเบ, เบเบนเปเบเปเบฒเบชเบฐเปเบซเบเบต) เปเบฅเบฐ เบเบนเปเบเบดเบเบเบฒเบก (เบเบนเปโเบเบดเบโเบเบฒเบกโ, เบชเปเบฒโเบฅเบญเบโ, subordinatesโ)โ. เบเบฒเบเบซเบเปเบฒ, เปเบฎเบฑเบเบซเบเปเบฒเบเบตเปเปเบเบฑเบเบเบนเปเบเปเบฒเบชเปเบฒเบฅเบฑเบเบเบฒเบเปเบเปเบเบชเปเบงเบเบเบตเป, เบฎเบฑเบเบเบดเบเบเบญเบเบชเปเบฒเบฅเบฑเบเบเบฒเบเปเบเปเบฎเบฑเบเบเปเปเบเบงเบฒเบกเบเบฑเบเบซเบกเบปเบเบเบตเปเบชเบปเปเบเปเบเบซเบฒเบกเบฑเบเปเบเบเบเบนเปเบเบฐเบฅเบดเบเปเบฅเบฐเปเบเบเบขเบฒเบเบเปเปเบเบงเบฒเบกเปเบซเปเบเบนเปเบเปเบฅเบดเปเบเบ. เปเบกเบทเปเบญเบเปเปเบเบงเบฒเบกเบเบทเบเบชเบปเปเบเปเบเบซเบฒเบซเบปเบงเบเปเปเปเบเปเบเบชเปเบงเบ, เบเบงเบเบกเบฑเบเบเบทเบ replicated เบเบฑเบเบเบธเบ nodes เบเบฒเบเบซเบเปเบฒเปเบฎเบฑเบเบซเบเปเบฒเบเบตเปเปเบเบฑเบเบเบนเปเบเบดเบเบเบฒเบกเบชเปเบฒเบฅเบฑเบเบเบฒเบเบดเบเบฑเบเบเบฑเปเบ. เปเบเปเบฅเบฐ node เบเบตเปเบกเบตเบเบฑเบเบเบถเบเบชเปเบฒเบฅเบฑเบเบเบฒเบเปเบเปเบเบชเปเบงเบเปเบกเปเบเปเบญเบตเปเบเบงเปเบฒ เปเบเบเบเบณเบฅเบญเบ. เบเบฒเบเบซเบเปเบฒเบชเบฒเบกเบฒเบเปเบฎเบฑเบเบซเบเปเบฒเบเบตเปเปเบเบฑเบเบเบนเปเบเปเบฒเบชเปเบฒเบฅเบฑเบเบเบฒเบเบชเปเบงเบเปเบฅเบฐเปเบเบฑเบเบเบนเปเบเบดเบเบเบฒเบกเบชเปเบฒเบฅเบฑเบเบเบปเบเบญเบทเปเบ.
เบเบนเปเบเบดเบเบเบฒเบกเบเบตเปเบเบฑเบเบเบธเบเปเปเบเบงเบฒเบกเบเบฑเบเบซเบกเบปเบเบเบตเปเบเบทเปเบเบเบเบนเปเบเปเบฒเปเบกเปเบเปเบญเบตเปเบเบงเปเบฒ synchronized replica (เบเบฒเบโเบเปเบฒโเบฅเบญเบโเบเบตเปโเบขเบนเปโเปเบโเบชเบฐโเบเบฒเบโเบเบตเป synchronizedโ, in-sync replicaโ)โ. เบเปเบฒเบเบฒเบเบซเบเปเบฒเบเบตเปเปเบฎเบฑเบเบซเบเปเบฒเบเบตเปเปเบเบฑเบเบเบนเปเบเปเบฒเบชเปเบฒเบฅเบฑเบเบเบฒเบเปเบเปเบเบชเปเบงเบเบซเบผเบธเบเบฅเบปเบ, เบเบฒเบเบซเบเปเบฒเปเบเปเบเบตเปเบเบฑเบเบชเบฐเปเบซเบกเบซเบผเบท synchronized เบชเปเบฒเบฅเบฑเบเบเบฒเบเปเบเปเบเบเบฑเบเบเบฑเปเบเบชเบฒเบกเบฒเบเบฎเบฑเบเบซเบเปเบฒเบเบตเปเบเบนเปเบเปเบฒ. เบกเบฑเบเปเบเบฑเบเบเบฒเบเบญเบญเบเปเบเบเบเบตเปเบกเบตเบเบงเบฒเบกเบเบทเบเบเบปเบเบขเปเบฒเบเบเปเปเบซเบเปเบฒเปเบเบทเปเบญ.
เบชเปเบงเบเบซเบเบถเปเบเบเบญเบเบเบฒเบเบเบฑเปเบเบเปเบฒเบเบนเปเบเบฐเบฅเบดเบเปเบกเปเบเบเบฒเบฅเบฒเบกเบดเปเบเบต acks, เปเบเบดเปเบเบเปเบฒเบเบปเบเบเปเบฒเบเบงเบ replicas เบเปเบญเบเปเบเปเบฎเบฑเบเบเบฒเบเบฎเบฑเบเบฎเบนเป (เบฎเบฑเบเบฎเบนเป) เบเปเปเบเบงเบฒเบกเบเปเบญเบเบเบตเปเบเบฐเบเบนเปเบเปเบฒเบฎเปเบญเบเบชเบฐเบซเบกเบฑเบเบเบฐเบชเบทเบเบเปเปเบชเบปเปเบ: 0, 1, เบซเบผเบทเบเบฑเบเบซเบกเบปเบ. เบเปเบฒเบเบฑเปเบเปเบเบฑเบ เบเบฑเบเบซเบกเบปเบ, เบซเบผเบฑเบเบเบฒเบเบเบฑเปเบเปเบกเบทเปเบญเปเบเปเบฎเบฑเบเบเปเปเบเบงเบฒเบก, เบเบนเปเบเปเบฒเบเบฐเบชเบปเปเบเบเปเบฒเบขเบทเบเบขเบฑเบเบเบฑเบเบเบทเบเปเบเบเปเบญเบเบเบนเปเบเบฐเบฅเบดเบเบเบฑเบเบเบตเบเบตเปเบกเบฑเบเปเบเปเบฎเบฑเบเบเบฒเบเบขเบทเบเบขเบฑเบ (เบเบฒเบเบฎเบฑเบเบฎเบนเป) เบเบญเบเบเบฑเบเบเบถเบเบเบฒเบเบซเบผเบฒเบเป cues (เบฅเบงเบกเบเบฑเบเบเบปเบงเบกเบฑเบเปเบญเบ) เบเปเบฒเบเบปเบเปเบเบเบซเบปเบงเบเปเปเบเบฑเปเบ. min.insync.replicas (เบเปเบฒเปเบฅเบตเปเบกเบเบปเปเบ 1). เบเปเบฒโเบซเบฒเบโเบงเปเบฒโเบเปเปโเบเบงเบฒเบกโเบเปเปโเบชเบฒโเบกเบฒเบ replicated เบชเบปเบโเบเบปเบโเบชเปเบฒโเปเบฅเบฑเบโ, เบซเบผเบฑเบโเบเบฒเบโเบเบฑเปเบโเบเบนเปโเบเบฐโเบฅเบดเบโเบเบฐโเบเบปเบโเปเบงเบฑเปเบโเบเปเบฒโเบฎเปเบญเบโเบชเบฐโเบซเบกเบฑเบ (NotEnoughReplicas เบซเบผเบท NotEnoughReplicasAfterAppend).
เบเบฒเบเบเบฑเปเบเบเปเบฒเบเบปเบเบเบฐเบเบดเบชเปเบฒเบเบซเบปเบงเบเปเปเบเบตเปเบกเบตเบเบฑเบเปเบเบเบฒเบเบเปเบฒเบฅเบญเบเบเบญเบ 3 (เบเบนเปเบเปเบฒ 1 เบเบปเบ, เบเบนเปเบเบดเบเบเบฒเบก 2 เบเบปเบเบเปเปเบเบฒเบเบดเบเบฑเบ) เปเบฅเบฐเบเบฒเบฅเบฒเบกเบดเปเบเบต. min.insync.replicas เบเบทเบเบเปเบฒเบเบปเบเปเบเบฑเบ 2. เปเบเบเปเบฅเบฐเบเบตเบเบตเป, เบเบธเปเบกเบเบฐเบญเบฐเบเบธเบเบฒเบเปเบซเปเบซเบเบถเปเบเบเบญเบเบเบฒเบเบซเบเปเบฒเบเบธเปเบกเบเบญเบเบเบฒเบเปเบเปเบเบเบฑเบเบซเบปเบงเบเปเปเบเบตเปเบเบฐเบฅเบปเบเปเบเปเบเบเบเปเปเบกเบตเบเบปเบเบเบฐเบเบปเบเบเปเปเบเปเบฒเบฎเปเบญเบเบชเบฐเบซเบกเบฑเบเบเบญเบเบฅเบนเบเบเปเบฒ.
เบเบตเปเปเบฎเบฑเบเปเบซเปเบเบงเบเปเบฎเบปเบฒเบเบฑเบเบเบทเบเปเบเบเปเบญเบเบเบฒเบเบเปเบฒเบเบตเปเบเบธเปเบเปเบเบตเบเปเบฅเปเบงเบฅเบฐเบซเบงเปเบฒเบเบเบฒเบเบเบฐเบเบดเบเบฑเบเปเบฅเบฐเบเบงเบฒเบกเบซเบเปเบฒเปเบเบทเปเบญเบเบท. Replication เปเบเบตเบเบเบทเปเบเปเบเบเบเปเบฒเปเบเปเบเปเบฒเบเบเบญเบเปเบงเบฅเบฒเบฅเปเบเปเบฒเปเบเบตเปเบกเปเบเบตเบกเบชเปเบฒเบฅเบฑเบเบเบฒเบเบขเบทเบเบขเบฑเบ (เบเบฒเบเบฎเบฑเบเบฎเบนเป) เบเบฒเบเบเบนเปเบเบดเบเบเบฒเบก. เปเบเบดเบเปเบกเปเบเบงเปเบฒ, เปเบเบทเปเบญเบเบเบฒเบเบงเปเบฒเบกเบฑเบเบเปเบฒเปเบเบตเบเบเบฒเบเปเบเบเบฐเบซเบเบฒเบ, replication เบขเปเบฒเบเบซเบเปเบญเบเบชเบฒเบก nodes เบกเบตเบเบฒเบเบเบฐเบเบดเบเบฑเบเปเบเบฑเปเบเบเบฝเบงเบเบฑเบเบเบฑเบเบชเบญเบ (เบเปเปเบชเบปเบเปเบเบเบฒเบเปเบเบตเปเบกเบเบถเปเบเบเบญเบเบเบฒเบเบเปเบฒเปเบเปเปเบเบเบงเบดเบเปเบเบทเบญเบเปเบฒเบ).
เปเบเบเบเบฒเบเบเปเบฒเปเบเปเปเบเบเบเบฒเบเบเบฒเบเบเปเบฒเบฅเบญเบเบเบตเป, Kafka เบชเบฐเบซเบฅเบฒเบเบซเบฅเบตเบเบฅเปเบฝเบเบเบงเบฒเบกเบเปเบฒเปเบเบฑเบเปเบเบเบฒเบเบเบฝเบเบเปเปเบเบงเบฒเบกเปเบเปเบฅเบฐเบเบปเบเปเบชเปเปเบเปเบเบเบดเบเบเปเบงเบเบเบฒเบเบเปเบฒเปเบเบตเบเบเบฒเบ. sync(). เปเบเปเบฅเบฐเบเปเปเบเบงเบฒเบกเบเบตเปเบเบทเบเบชเบปเปเบเปเบเบเบเบนเปเบเบฐเบฅเบดเบเบเบฐเบเบทเบเบเบฝเบเปเบชเปเบเบฑเบเบเบถเบเบเบฒเบเปเบเปเบเบชเปเบงเบ, เปเบเปเบเบฑเปเบเบเบตเปเปเบเปเบชเบปเบเบเบฐเบเบฒเปเบเบเบปเบเบเบต 2, เบเบฒเบเบเบฝเบเปเบเบฅเปเปเบกเปเบเปเบฎเบฑเบเปเบเปเบเบทเปเบญเบเบเบปเปเบเปเบ buffer เบเบญเบเบฅเบฐเบเบปเบเบเบฐเบเบดเบเบฑเบเบเบฒเบ. เบเปเบฒเบเปเปเบเบงเบฒเบกเบเบตเปเบเบทเบเบเปเบฒเบฅเบญเบเบเบฑเบเบเบปเบงเบขเปเบฒเบ Kafka เบญเบทเปเบเปเบฅเบฐเบขเบนเปเปเบเบเบงเบฒเบกเบเบปเบเบเปเบฒเบเบญเบเบกเบฑเบ, เบเบฒเบเบชเบนเบเปเบชเบเบเบนเปเบเปเบฒเบเปเปเปเบเปเบซเบกเบฒเบเบเบงเบฒเบกเบงเปเบฒเบเปเปเบเบงเบฒเบกเบเบปเบงเบกเบฑเบเปเบญเบเปเบเปเบชเบนเบเปเบชเบ - เบกเบฑเบเบชเบฒเบกเบฒเบเบเบทเบเบเปเบฒเปเบเปเบเบ replica synchronized.
เบเบฒเบเบเบฐเบเบดเปเบชเบเบเบฒเบเบเบฐเบเบดเบเบฑเบเบเบฒเบเบเบฐเบเบดเบเบฑเบเบเบฒเบ sync() เบซเบกเบฒเบเบเบงเบฒเบกเบงเปเบฒ Kafka เบชเบฒเบกเบฒเบเปเบเปเบฎเบฑเบเบเปเปเบเบงเบฒเบกเปเบงเปเบเบปเปเบฒเบเบตเปเบกเบฑเบเบชเบฒเบกเบฒเบเบเบฝเบเบเบงเบเบกเบฑเบเปเบงเปเปเบเบเบงเบฒเบกเบเบปเบเบเปเบฒ. เบเบปเบเบเบฑเบเบเปเบฒเบก, เบเบดเปเบเปเบเบปเปเบฒเบชเบฒเบกเบฒเบเบซเบผเบตเบเบฅเปเบฝเบเบเบฒเบเบฅเปเบฒเบเปเปเบงเบเบเบงเบฒเบกเบเบณเปเบเปเบชเปเปเบเปเบเปเบเปเบเบปเบเปเบเบปเปเบฒเปเบ, เบเปเปเบเบดเปเบเบเบตเบเบงเปเบฒ. เบชเปเบฒเบฅเบฑเบเปเบซเบเบเบปเบเบเบตเป, เบกเบฑเบเบเปเปเปเบกเปเบเปเบฅเบทเปเบญเบเปเบเบเบเบตเปเบเบฒเบเบซเบเปเบฒ Kafka เบเบฐเบเบทเบเบเบฑเบเบชเบฑเบเบซเบเปเบงเบเบเบงเบฒเบกเบเปเบฒ 64 GB เบซเบผเบทเบซเบผเบฒเบเบเบงเปเบฒเบเบฑเปเบ. เบเบฒเบเปเบเปเบเบงเบฒเบกเบเบปเบเบเปเบฒเบเบตเปเบซเบกเบฒเบเบเบงเบฒเบกเบงเปเบฒเบเบปเบงเบขเปเบฒเบ Kafka เบเบฝเบงเบชเบฒเบกเบฒเบเบเปเบฒเปเบเบตเบเบเบฒเบเปเบเปเบขเปเบฒเบเบเปเบฒเบเบเบฒเบเบเปเบงเบเบเบงเบฒเบกเปเบงเบซเบผเบฒเบเบเบฑเบเปเบเบทเปเบญเปเบงเบเปเบงเบฒเบเบฒเบเบซเบเปเบฒเบเปเปเบเบงเบฒเบกเปเบเบเบเบฑเปเบเปเบเบตเบก.
Kafka เบเบฑเบเบชเบฒเบกเบฒเบเบเบทเบเบเบฑเปเบเบเปเบฒเปเบเบทเปเบญเบเปเบฒเปเบเปเบเบฒเบเบเปเบฒเปเบเบตเบเบเบฒเบ sync() เบเบฑเบเบเบธเบเบเปเปเบเบงเบฒเบก. เปเบเบทเปเบญเบเบเบฒเบเบงเปเบฒเบเบธเบเบชเบดเปเบเบเบธเบเบขเปเบฒเบเบขเบนเปเปเบ Kafka เปเบกเปเบเปเบเบฑเบเบเบธเบ, เบเบปเบงเบเบดเบเปเบฅเปเบงเบกเบฑเบเปเบฎเบฑเบเบงเบฝเบเปเบเปเบเบตเบชเปเบฒเบฅเบฑเบเบเปเบฅเบฐเบเบตเบเบฒเบเบเปเบฒเปเบเปเบเปเบฒเบเบงเบเบซเบผเบฒเบเปเบฅเบฐเปเบเบฑเบเปเบเบทเปเบญเบเบกเบทเบเบตเปเปเบเบฑเบเบเบฐเปเบซเบเบเบชเปเบฒเบฅเบฑเบเบเบนเปเปเบเปเบเบตเปเบเปเบญเบเบเบฒเบเบเบฒเบเบฎเบฑเบเบเบฐเบเบฑเบเบเบตเปเปเบเบฑเปเบกเปเบเบเบซเบผเบฒเบ. เบชเปเบงเบเปเบซเบเปเบเบญเบเบเบฒเบเบเบฐเบเบดเบเบฑเบเบญเบฑเบเบเปเบฅเบดเบชเบธเบเบเบญเบ Kafka เปเบกเปเบเบกเบฒเบเบฒเบเบเปเปเบเบงเบฒเบกเบเบตเปเบเบทเบเบชเบปเปเบเปเบเบซเบฒเบเบฒเบเบซเบเปเบฒเปเบเบฑเบเปเบเบฑเบเปเบเบฑเบเปเบฅเบฐเบเปเปเบเบงเบฒเบกเปเบซเบผเบปเปเบฒเบเบตเปเบเบทเบเบญเปเบฒเบเบเบฒเบเบเบฒเบเบซเบเปเบฒเปเบเบเปเบญเบเปเบกเปเบเบฒเบกเบฅเปเบฒเบเบฑเบเปเบเบเปเบเป
เบเบฒเบเบเบฐเบเบดเบเบฑเบเบเบตเปเบเบตเบเบงเปเบฒเบซเบผเบฒเบเปเบกเปเบเปเบเบฑเบเปเบเปเบเปเปเบเบเบธเปเบก Kafka เบเปเบงเบฒเบเบฑเบเบเบฒเบเบซเบเปเบฒ Kafka เบเบฝเบง, เปเบเบทเปเบญเบเบเบฒเบเบงเปเบฒเบเบฒเบเปเบเปเบเบเบฑเบเบซเบปเบงเบเปเปเบชเบฒเบกเบฒเบเบเบฐเบซเบเบฒเบเบญเบญเบเปเบเบเบปเปเบงเปเบเบทเปเบญเบเบเบฑเบเปเบเบเบเปเบฒเบเบซเบฒเบเบซเบผเบฒเบ.
เบเบปเบเปเบเปเบฎเบฑเบ
เปเบเบเบปเบเบเบตเป, เบเบงเบเปเบฎเบปเบฒเปเบเปเปเบเบดเปเบเบงเบดเบเบตเบเบฒเบเบชเบฐเบเบฒเบเบฑเบเบเบฐเบเบฐเบเปเบฒ Kafka reimagines เบเบงเบฒเบกเบชเปเบฒเบเบฑเบเบฅเบฐเบซเบงเปเบฒเบเบฅเบนเบเบเปเบฒเปเบฅเบฐเบเบฒเบเบซเบเปเบฒเปเบเบทเปเบญเบชเบฐเบซเบเบญเบเบเปเปเบชเบปเปเบเบเปเปเบเบงเบฒเบกเบเบตเปเปเบเบฑเปเบกเปเบเบเบขเปเบฒเบเบเปเปเบซเบเปเบฒเปเบเบทเปเบญ, เบเบตเปเบกเบตเบเบปเบเบเบฐเบฅเบดเบเบซเบผเบฒเบเปเบเบปเปเบฒเบซเบผเบฒเบเบเปเบงเบฒเบเบญเบเบเบฒเบเบซเบเปเบฒเบเปเปเบเบงเบฒเบกเบเปเบฒเบกเบฐเบเบฒ. เบเบงเบเปเบฎเบปเบฒเปเบเปเบเบถเบเบชเบฒเบซเบฒเบฅเบทเบเปเบฝเบงเบเบฑเบเบซเบเปเบฒเบเบตเปเบกเบฑเบเปเบเปเปเบเบทเปเบญเบเบฑเบเบฅเบธเปเบเบปเปเบฒเบซเบกเบฒเบเบเบตเปเปเบฅเบฐเปเบเบดเปเบเบชเบฑเปเบเปเบเปเบฝเบงเบเบฑเบเบชเบฐเบเบฒเบเบฑเบเบเบฐเบเบฐเบเปเบฒเบเบญเบเปเบญเบฑเบเบเบฅเบดเปเบเบเบฑเบเบเบตเปเบชเบฐเบซเบเบญเบเบเบฒเบเปเบฎเบฑเบเบงเบฝเบเบเบตเป. เปเบเบเบปเบเบเปเปเปเบ, เบเบงเบเปเบฎเบปเบฒเบเบฐเปเบเบดเปเบเบเบฑเบเบซเบฒเบเบปเปเบงเปเบเบเบตเปเบเปเบฒเบฎเปเบญเบเบชเบฐเบซเบกเบฑเบเบเบตเปเบญเบตเบเปเบชเปเบเปเปเบเบงเบฒเบกเบเบตเปเบเปเบญเบเบเบฒเบเปเบเบทเปเบญเปเบเปเปเบเปเบฅเบฐเบเบถเบเบชเบฒเบซเบฒเบฅเบทเบเบธเบเบเบฐเบชเบฒเบเบชเปเบฒเบฅเบฑเบเบเบฒเบเบเบฑเบเบเบฒเบเบเบฑเบเบเบงเบเบกเบฑเบ. เบเบงเบเปเบฎเบปเบฒเบเบฐเบชเบดเปเบเบชเบธเบเบเบปเบเปเบเบเบเบฒเบเบญเบฐเบเบดเบเบฒเบเบงเบดเบเบตเบเบฒเบเบชเบปเบเบเบฐเบเบฒเบเปเบฝเบงเบเบฑเบเปเบเบฑเบเปเบเปเบฅเบขเบตเบเบฒเบเบชเบปเปเบเบเปเปเบเบงเบฒเบกเปเบเบเบเบปเปเบงเปเบเปเบเบทเปเบญเปเบซเปเบเปเบฒเบเบชเบฒเบกเบฒเบเบเบฐเปเบกเบตเบเบเบงเบฒเบกเปเบซเบกเบฒเบฐเบชเบปเบกเบเบฑเบเบเปเบฅเบฐเบเบตเบเบฒเบเบเปเบฒเปเบเปเบเบญเบเบเปเบฒเบ.
เบเบฒเบเบชเปเบงเบเบเบตเปเปเบเบเปเบฒเบเบกเบฒ:
เบเบฒเบเปเบเบชเบณเปเบฅเบฑเบเปเบฅเปเบง:
เบเบดเบโเบเบฒเบกโเบเบญเบโเบเปเปโเปเบโฆ
เบเบฝเบเปเบเปเบเบนเปเปเบเปเบฅเบปเบเบเบฐเบเบฝเบเบชเบฒเบกเบฒเบเปเบเบปเปเบฒเบฎเปเบงเบกเปเบเบเบฒเบเบชเปเบฒเบซเบผเบงเบ.
Kafka เบเบทเบเบเปเบฒเปเบเปเปเบเบญเบปเบเบเบฒเบเบเบฑเบเบเบฑเปเบเบเบญเบเบเปเบฒเบเบเป?
-
เปเบกเปเบโเปเบฅเปเบง
-
เบเปเปโเบกเบต
-
เปเบกเบทเปเบญเบเปเบญเบเปเบเป, เบเบฝเบงเบเบตเปเบเปเปเปเบเป
-
เบเบงเบเปเบฎเบปเบฒเบงเบฒเบเปเบเบเบเบตเปเบเบฐเบเปเบฒเปเบเป
38 เบเบนเปเปเบเปเบฅเบปเบเบเบฐเปเบเบเบชเบฝเบ. 8 เบเบนเปเปเบเปเบเบปเบ.
เปเบซเบผเปเบเบเปเปเบกเบนเบ: www.habr.com