我正在尝试使用骆驼向kafka发送消息 . 我从camel git repo中获取了camel示例代码 . 我运行MessagePublisherClient.java并得到以下异常 . 我在属性文件中配置了我的Kafka服务器名称,端口和主题详细信息 .
为什么我得到此异常以及如何修复此异常 .
如果我尝试使用camel 2.14.1版本并根据2.14.1进行代码更改 . 我能够推送消息 . 但为什么最新版本会出错 .
骆驼回购:https://github.com/apache/camel/tree/master/examples/camel-example-kafka
Java 1.8 Camel:2.21.0
错误:
Message History
---------------------------------------------------------------------------------------------------------------------------------------
RouteId ProcessorId Processor Elapsed (ms)
[DirectToKafka ] [DirectToKafka ] [direct://kafkaStart ] [ 60017]
[DirectToKafka ] [to1 ] [kafka:{{producer.topic}} ] [ 60013]
Stacktrace
---------------------------------------------------------------------------------------------------------------------------------------
org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
Exception in thread "main" org.apache.camel.CamelExecutionException: Exception occurred during execution on the exchange: Exchange[ID-host-1513537490104-0-1]
at org.apache.camel.util.ObjectHelper.wrapCamelExecutionException(ObjectHelper.java:1846)
at org.apache.camel.util.ExchangeHelper.extractResultBody(ExchangeHelper.java:713)
at org.apache.camel.impl.DefaultProducerTemplate.extractResultBody(DefaultProducerTemplate.java:515)
at org.apache.camel.impl.DefaultProducerTemplate.extractResultBody(DefaultProducerTemplate.java:511)
at org.apache.camel.impl.DefaultProducerTemplate.sendBodyAndHeaders(DefaultProducerTemplate.java:259)
at org.apache.camel.impl.DefaultProducerTemplate.sendBodyAndHeaders(DefaultProducerTemplate.java:253)
at org.apache.camel.example.kafka.MessagePublisherClient.main(MessagePublisherClient.java:91)
Caused by: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.