1. If the producer produces faster than the broker can take, the records will be buffered in memory
2. buffer.memory=33554432(32MB): the size of the send buffer
3. That buffer will fill up over time and fill back down when the throughput to the broker increases
4. If that buffer is full (all 32MB), then the .send() method will start to block (won't return right away)
5. max.block.ms=60000: the time the .send() will block until throwing a exception. Exceptions are basically thrown when
- The producer has filled up its buffer
- The broker is not accepting any new data
- 60 seconds has elapsed.
6. If you hit an exception hit that usually means your brokers aredown or overloaded as they can't respond to requests
댓글 없음:
댓글 쓰기