Hi, kafka is a partitioned system, so not all the servers have the complete
data set.
The producer does not know whether the topic is not exist, or some brokers
are down, it just tries to query again and again until timeout occurs. I
think org.apache.kafka.common.errors.TimeoutException makes sens
Hi there-
The error message returned when trying to produce to a nonexistent kafka topic
(with auto topic creation disabled) is non obvious. It returns an error
message of the form:
"org.apache.kafka.common.errors.TimeoutException: Failed to update metadata
after xx ms"
where xx is a small n
