Почему обратный вызов в методе продюсера. ⇐ JAVA

[Anonymous]

Я в настоящее время отправляю сообщения в Кафку, как так: < /p>

Код: Выделить всё

try {
producer.send(record, new Callback() {
public void onCompletion(RecordMetadata metadata, Exception e) {
System.out.println(metadata);
System.out.println(e);
if (e != null) {
System.out.println(e);
try {
throw(e);
} catch (InvalidTopicException er) {
logger.error("Unrecoverable error: ", er);
System.exit(-1);
} //...otherfatalexceptions...
catch (UnknownServerException er) {
logger.error("Unrecoverable error: ", er);
System.exit(-1);
} catch (Exception er) {
logger.error("Failed to send message to topic:" + topic, er);
}
}
}
});
} catch (Exception e) {
logger.error("Failed to send message to topic:" + topic, e);
}

Я использую продюсер.send и не жду возврата метаданных записей перед отправкой следующей записи в очередь, поскольку это займет долго. /> Производитель инициализируется так: < /p>
producer = new KafkaProducer(properties);
< /code>
со следующими свойствами < /p>
Properties mainKafkaProperties = new Properties();
mainKafkaProperties.put("bootstrap.servers", kafkaUrl);
mainKafkaProperties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
mainKafkaProperties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
mainKafkaProperties.put("acks", "all");
< /code>
Когда сообщения отправляются должным образом, System.out.println (Metadata); Строка правильно печатает метаданные, показывающие, что сообщения отправляются должным образом,
, но когда я удаляю тему для моделирования Invalidtopicexception < /code> вместо выполнения кода в методе Catch я получаю только следующее предупреждение:
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error while fetching metadata with correlation id 97 : {em_om_messages_local=UNKNOWN_TOPIC_OR_PARTITION}< /code> < /p>
Используется библиотека Kafka: org.apache.kafka.clients
Я запускаю программу на eclipse Debugger < /p>
Я получаю одинаковую ошибку, независимо>

Подробнее здесь: https://stackoverflow.com/questions/771 ... ure-to-sen