THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
Versions Compared
compared with
Key
- This line was added.
- This line was removed.
- Formatting was changed.
...
The changes can refer to the example PR: https://github.com/apache/kafka/pull/13335/files
Add two configures with tiny code changes related which control the timeout in KafkaProducer#send
1. Two configures added
producer's configure | configure item | default value |
includeWaitTimeOnMetadataInMaxBlockTime | max.block.ms.include.metadata | false |
maxWaitTimeMsOnMetadata |
2. Code changes
By default, includeWaitTimeOnMetadataInMaxBlockTime is true, all of the behaviors are not changed.
...