Affects Version/s: 0.9.0.1
Fix Version/s: None
producer.send() is blocked for max.block.ms (default 60 seconds) if the destination topic doesn't exist and if their automatic creation is disabled. Warning from NetworkClient containing UNKNOWN_TOPIC_OR_PARTITION is logged every 100 ms in a loop until the 60 seconds timeout expires, but the operation is not recoverable.
- Kafka 0.9.0.1 with default configuration and auto.create.topics.enable=false
- Kafka 0.9.0.1 clients.
Example minimalist code
- Configure max.block.ms = 0 in producer to prevent blocking and return from send() immediately. But be careful, I'm not sure if is it safe and can't cause something even worse