Caused by: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
int count = 0; while(count < maxMessages) { producer.send(new ProducerRecord("test", "message --- #"+count++)).get(); System.out.println("Message send.."+count);
Re: Caused by: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
t; Producer producer = new KafkaProducer(props); > int maxMessages = 1000; > > int count = 0; > while(count < maxMessages) { > producer.send(new ProducerRecord String>("test", "message ---