You can have errors at multiple levels. I'm not sure on which one you only
want to retry once. Kafka will retry to some degree always, even if you
don't have retries in Kafka configured. When the connection breaks the
retries value is needed to still send the message. By using Camel you have
yet another level at which a retry can be instantiated.
I think when you look closely to the log, and which level was the cause of
the error, you should be able to figure out whether you need to change the
Kafka or Camel settings.
On Mon, Mar 28, 2016, 17:55 kumar5 <deelip.kum...@gmail.com> wrote:
> I have configured camel-Kafka producer (camel 2.16.2) topic(USER_REQ_TOPIC)
> if any exception throws then only once it has to re-tries but in loges
> shows 5 tries and at end it says only one rites it did. I want Kafka has
> to re-tries only once if any exception happens. Can you please help me to
> understand and fix this issue.
>
> <route id="kafkaRoute">
> <from uri="seda:kafkaProducer" />
> <log message="${body}" loggingLevel="INFO" />
> <to
> uri="kafka:1.0.10.22:9092?topic=SER_REQ_TOPIC&messageSendMaxRetries=1"
> />
>
> </route>
>
> Brief exception
> //kafkaProducer] kafka.client.ClientUtils$ : Fetching topic
> metadata with correlation id 0 for topics [Set(USER_REQ_TOPIC)] from broker
> [id:0,host:1.0.10.22,port:9092] failed
> //kafkaProducer] kafka.client.ClientUtils$ : Fetching topic
> metadata with correlation id 1 for topics [Set(USER_REQ_TOPIC)] from broker
> [id:0,host:1.0.10.22,port:9092] failed
> //kafkaProducer] kafka.client.ClientUtils$ : Fetching topic
> metadata with correlation id 2 for topics [Set(USER_REQ_TOPIC)] from broker
> [id:0,host:1.0.10.22,port:9092] failed
> //kafkaProducer] kafka.client.ClientUtils$ : Fetching topic
> metadata with correlation id 3 for topics [Set(USER_REQ_TOPIC)] from broker
> [id:0,host:1.0.10.22,port:9092] failed
> //kafkaProducer] kafka.client.ClientUtils$ : Fetching topic
> metadata with correlation id 4 for topics [Set(USER_REQ_TOPIC)] from broker
> [id:0,host:1.0.10.22,port:9092] failed
>
>
> kafka.common.FailedToSendMessageException: Failed to send messages after 1
> tries.
> at
>
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.Producer.send(Producer.scala:77)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.javaapi.producer.Producer.send(Producer.scala:33)
> ~[kafka_2.11-0.8.2.2.jar:na]
>
>
>
> complete stack trace exception details :
>
> -28 09:33:27.695 WARN
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] o.a.camel.component.kafka.KafkaProducer : No message key
> or partition key set
> 2016-03-28 09:33:27.889 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.client.ClientUtils$ : Fetching
> metadata from broker id:0,host:1.0.10.22,port:9092 with correlation id 0
> for
> 1 topic(s) Set(USER_REQ_TOPIC)
> 2016-03-28 09:33:28.908 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.producer.SyncProducer : Connected to
> 1.0.10.22:9092 for producing
> 2016-03-28 09:33:28.909 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.producer.SyncProducer : Disconnecting
> from 1.0.10.22:9092
> 2016-03-28 09:33:28.915 WARN
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.client.ClientUtils$ : Fetching topic
> metadata with correlation id 0 for topics [Set(USER_REQ_TOPIC)] from broker
> [id:0,host:1.0.10.22,port:9092] failed
>
> java.nio.channels.ClosedChannelException: null
> at kafka.network.BlockingChannel.send(BlockingChannel.scala:100)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:73)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.send(SyncProducer.scala:113)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:58)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$1.apply$mcV$sp(DefaultEventHandler.scala:67)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Utils$.swallow(Utils.scala:172)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Utils$.swallowError(Utils.scala:45)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:67)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.Producer.send(Producer.scala:77)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.javaapi.producer.Producer.send(Producer.scala:33)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> org.apache.camel.component.kafka.KafkaProducer.process(KafkaProducer.java:93)
> [camel-kafka-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.impl.InterceptSendToEndpoint$1.process(InterceptSendToEndpoint.java:167)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:141)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:460)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:121)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.component.seda.SedaConsumer.sendToConsumers(SedaConsumer.java:298)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.doRun(SedaConsumer.java:207)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.run(SedaConsumer.java:154)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> [na:1.8.0_73]
> at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> [na:1.8.0_73]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_73]
>
> 2016-03-28 09:33:28.915 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.producer.SyncProducer : Disconnecting
> from 1.0.10.22:9092
> 2016-03-28 09:33:28.916 ERROR
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.utils.Utils$ : fetching topic
> metadata for topics [Set(USER_REQ_TOPIC)] from broker
> [ArrayBuffer(id:0,host:1.0.10.22,port:9092)] failed
>
> kafka.common.KafkaException: fetching topic metadata for topics
> [Set(USER_REQ_TOPIC)] from broker
> [ArrayBuffer(id:0,host:1.0.10.22,port:9092)] failed
> at
> kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:72)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$1.apply$mcV$sp(DefaultEventHandler.scala:67)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Utils$.swallow(Utils.scala:172)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Utils$.swallowError(Utils.scala:45)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:67)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.Producer.send(Producer.scala:77)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.javaapi.producer.Producer.send(Producer.scala:33)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> org.apache.camel.component.kafka.KafkaProducer.process(KafkaProducer.java:93)
> [camel-kafka-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.impl.InterceptSendToEndpoint$1.process(InterceptSendToEndpoint.java:167)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:141)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:460)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:121)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.component.seda.SedaConsumer.sendToConsumers(SedaConsumer.java:298)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.doRun(SedaConsumer.java:207)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.run(SedaConsumer.java:154)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> [na:1.8.0_73]
> at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> [na:1.8.0_73]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_73]
> Caused by: java.nio.channels.ClosedChannelException: null
> at kafka.network.BlockingChannel.send(BlockingChannel.scala:100)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:73)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.send(SyncProducer.scala:113)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:58)
> ~[kafka_2.11-0.8.2.2.jar:na]
> ... 24 common frames omitted
>
> 2016-03-28 09:33:28.919 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.client.ClientUtils$ : Fetching
> metadata from broker id:0,host:1.0.10.22,port:9092 with correlation id 1
> for
> 1 topic(s) Set(USER_REQ_TOPIC)
> 2016-03-28 09:33:29.922 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.producer.SyncProducer : Connected to
> 1.0.10.22:9092 for producing
> 2016-03-28 09:33:29.922 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.producer.SyncProducer : Disconnecting
> from 1.0.10.22:9092
> 2016-03-28 09:33:29.924 WARN
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.client.ClientUtils$ : Fetching topic
> metadata with correlation id 1 for topics [Set(USER_REQ_TOPIC)] from broker
> [id:0,host:1.0.10.22,port:9092] failed
>
> java.nio.channels.ClosedChannelException: null
> at kafka.network.BlockingChannel.send(BlockingChannel.scala:100)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:73)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.send(SyncProducer.scala:113)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:58)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.BrokerPartitionInfo.getBrokerPartitionInfo(BrokerPartitionInfo.scala:49)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$getPartitionListForTopic(DefaultEventHandler.scala:186)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:150)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:149)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
> [scala-library-2.11.7.jar:na]
> at
> scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
> [scala-library-2.11.7.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler.partitionAndCollate(DefaultEventHandler.scala:149)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:95)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:72)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.Producer.send(Producer.scala:77)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.javaapi.producer.Producer.send(Producer.scala:33)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> org.apache.camel.component.kafka.KafkaProducer.process(KafkaProducer.java:93)
> [camel-kafka-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.impl.InterceptSendToEndpoint$1.process(InterceptSendToEndpoint.java:167)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:141)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:460)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:121)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.component.seda.SedaConsumer.sendToConsumers(SedaConsumer.java:298)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.doRun(SedaConsumer.java:207)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.run(SedaConsumer.java:154)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> [na:1.8.0_73]
> at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> [na:1.8.0_73]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_73]
>
> 2016-03-28 09:33:29.924 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.producer.SyncProducer : Disconnecting
> from 1.0.10.22:9092
> 2016-03-28 09:33:29.926 ERROR
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] k.producer.async.DefaultEventHandler : Failed to
> collate messages by topic, partition due to: fetching topic metadata for
> topics [Set(USER_REQ_TOPIC)] from broker
> [ArrayBuffer(id:0,host:1.0.10.22,port:9092)] failed
> 2016-03-28 09:33:29.927 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] k.producer.async.DefaultEventHandler : Back off for
> 100 ms before retrying send. Remaining retries = 1
> 2016-03-28 09:33:30.030 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.client.ClientUtils$ : Fetching
> metadata from broker id:0,host:1.0.10.22,port:9092 with correlation id 2
> for
> 1 topic(s) Set(USER_REQ_TOPIC)
> 2016-03-28 09:33:31.034 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.producer.SyncProducer : Connected to
> 1.0.10.22:9092 for producing
> 2016-03-28 09:33:31.035 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.producer.SyncProducer : Disconnecting
> from 1.0.10.22:9092
> 2016-03-28 09:33:31.037 WARN
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.client.ClientUtils$ : Fetching topic
> metadata with correlation id 2 for topics [Set(USER_REQ_TOPIC)] from broker
> [id:0,host:1.0.10.22,port:9092] failed
>
> java.nio.channels.ClosedChannelException: null
> at kafka.network.BlockingChannel.send(BlockingChannel.scala:100)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:73)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.send(SyncProducer.scala:113)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:58)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:78)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Utils$.swallow(Utils.scala:172)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Utils$.swallowError(Utils.scala:45)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:78)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.Producer.send(Producer.scala:77)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.javaapi.producer.Producer.send(Producer.scala:33)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> org.apache.camel.component.kafka.KafkaProducer.process(KafkaProducer.java:93)
> [camel-kafka-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.impl.InterceptSendToEndpoint$1.process(InterceptSendToEndpoint.java:167)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:141)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:460)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:121)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.component.seda.SedaConsumer.sendToConsumers(SedaConsumer.java:298)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.doRun(SedaConsumer.java:207)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.run(SedaConsumer.java:154)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> [na:1.8.0_73]
> at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> [na:1.8.0_73]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_73]
>
> 2016-03-28 09:33:31.038 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.producer.SyncProducer : Disconnecting
> from 1.0.10.22:9092
> 2016-03-28 09:33:31.039 ERROR
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.utils.Utils$ : fetching topic
> metadata for topics [Set(USER_REQ_TOPIC)] from broker
> [ArrayBuffer(id:0,host:1.0.10.22,port:9092)] failed
>
> kafka.common.KafkaException: fetching topic metadata for topics
> [Set(USER_REQ_TOPIC)] from broker
> [ArrayBuffer(id:0,host:1.0.10.22,port:9092)] failed
> at
> kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:72)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:78)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Utils$.swallow(Utils.scala:172)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Utils$.swallowError(Utils.scala:45)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:78)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.Producer.send(Producer.scala:77)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.javaapi.producer.Producer.send(Producer.scala:33)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> org.apache.camel.component.kafka.KafkaProducer.process(KafkaProducer.java:93)
> [camel-kafka-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.impl.InterceptSendToEndpoint$1.process(InterceptSendToEndpoint.java:167)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:141)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:460)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:121)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.component.seda.SedaConsumer.sendToConsumers(SedaConsumer.java:298)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.doRun(SedaConsumer.java:207)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.run(SedaConsumer.java:154)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> [na:1.8.0_73]
> at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> [na:1.8.0_73]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_73]
> Caused by: java.nio.channels.ClosedChannelException: null
> at kafka.network.BlockingChannel.send(BlockingChannel.scala:100)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:73)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.send(SyncProducer.scala:113)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:58)
> ~[kafka_2.11-0.8.2.2.jar:na]
> ... 24 common frames omitted
>
> 2016-03-28 09:33:31.040 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.client.ClientUtils$ : Fetching
> metadata from broker id:0,host:1.0.10.22,port:9092 with correlation id 3
> for
> 1 topic(s) Set(USER_REQ_TOPIC)
> 2016-03-28 09:33:32.065 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.producer.SyncProducer : Connected to
> 1.0.10.22:9092 for producing
> 2016-03-28 09:33:32.066 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.producer.SyncProducer : Disconnecting
> from 1.0.10.22:9092
> 2016-03-28 09:33:32.067 WARN
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.client.ClientUtils$ : Fetching topic
> metadata with correlation id 3 for topics [Set(USER_REQ_TOPIC)] from broker
> [id:0,host:1.0.10.22,port:9092] failed
>
> java.nio.channels.ClosedChannelException: null
> at kafka.network.BlockingChannel.send(BlockingChannel.scala:100)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:73)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.send(SyncProducer.scala:113)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:58)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.BrokerPartitionInfo.getBrokerPartitionInfo(BrokerPartitionInfo.scala:49)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$getPartitionListForTopic(DefaultEventHandler.scala:186)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:150)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:149)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
> [scala-library-2.11.7.jar:na]
> at
> scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
> [scala-library-2.11.7.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler.partitionAndCollate(DefaultEventHandler.scala:149)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:95)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:72)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.Producer.send(Producer.scala:77)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.javaapi.producer.Producer.send(Producer.scala:33)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> org.apache.camel.component.kafka.KafkaProducer.process(KafkaProducer.java:93)
> [camel-kafka-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.impl.InterceptSendToEndpoint$1.process(InterceptSendToEndpoint.java:167)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:141)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:460)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:121)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.component.seda.SedaConsumer.sendToConsumers(SedaConsumer.java:298)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.doRun(SedaConsumer.java:207)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.run(SedaConsumer.java:154)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> [na:1.8.0_73]
> at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> [na:1.8.0_73]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_73]
>
> 2016-03-28 09:33:32.067 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.producer.SyncProducer : Disconnecting
> from 1.0.10.22:9092
> 2016-03-28 09:33:32.068 ERROR
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] k.producer.async.DefaultEventHandler : Failed to
> collate messages by topic, partition due to: fetching topic metadata for
> topics [Set(USER_REQ_TOPIC)] from broker
> [ArrayBuffer(id:0,host:1.0.10.22,port:9092)] failed
> 2016-03-28 09:33:32.068 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] k.producer.async.DefaultEventHandler : Back off for
> 100 ms before retrying send. Remaining retries = 0
> 2016-03-28 09:33:32.174 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.client.ClientUtils$ : Fetching
> metadata from broker id:0,host:1.0.10.22,port:9092 with correlation id 4
> for
> 1 topic(s) Set(USER_REQ_TOPIC)
> 2016-03-28 09:33:33.192 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.producer.SyncProducer : Connected to
> 1.0.10.22:9092 for producing
> 2016-03-28 09:33:33.192 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.producer.SyncProducer : Disconnecting
> from 1.0.10.22:9092
> 2016-03-28 09:33:33.193 WARN
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.client.ClientUtils$ : Fetching topic
> metadata with correlation id 4 for topics [Set(USER_REQ_TOPIC)] from broker
> [id:0,host:1.0.10.22,port:9092] failed
>
> java.nio.channels.ClosedChannelException: null
> at kafka.network.BlockingChannel.send(BlockingChannel.scala:100)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:73)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.send(SyncProducer.scala:113)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:58)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:78)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Utils$.swallow(Utils.scala:172)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Utils$.swallowError(Utils.scala:45)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:78)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.Producer.send(Producer.scala:77)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.javaapi.producer.Producer.send(Producer.scala:33)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> org.apache.camel.component.kafka.KafkaProducer.process(KafkaProducer.java:93)
> [camel-kafka-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.impl.InterceptSendToEndpoint$1.process(InterceptSendToEndpoint.java:167)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:141)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:460)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:121)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.component.seda.SedaConsumer.sendToConsumers(SedaConsumer.java:298)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.doRun(SedaConsumer.java:207)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.run(SedaConsumer.java:154)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> [na:1.8.0_73]
> at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> [na:1.8.0_73]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_73]
>
> 2016-03-28 09:33:33.193 INFO
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.producer.SyncProducer : Disconnecting
> from 1.0.10.22:9092
> 2016-03-28 09:33:33.194 ERROR
> [RdluRestService,cd3ce6a80be37e22,cd3ce6a80be37e22,false] 2136 ---
> [//kafkaProducer] kafka.utils.Utils$ : fetching topic
> metadata for topics [Set(USER_REQ_TOPIC)] from broker
> [ArrayBuffer(id:0,host:1.0.10.22,port:9092)] failed
>
> kafka.common.KafkaException: fetching topic metadata for topics
> [Set(USER_REQ_TOPIC)] from broker
> [ArrayBuffer(id:0,host:1.0.10.22,port:9092)] failed
> at
> kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:72)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:78)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Utils$.swallow(Utils.scala:172)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.utils.Utils$.swallowError(Utils.scala:45)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:78)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.Producer.send(Producer.scala:77)
> [kafka_2.11-0.8.2.2.jar:na]
> at kafka.javaapi.producer.Producer.send(Producer.scala:33)
> [kafka_2.11-0.8.2.2.jar:na]
> at
>
> org.apache.camel.component.kafka.KafkaProducer.process(KafkaProducer.java:93)
> [camel-kafka-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.impl.InterceptSendToEndpoint$1.process(InterceptSendToEndpoint.java:167)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:141)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:460)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:121)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.component.seda.SedaConsumer.sendToConsumers(SedaConsumer.java:298)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.doRun(SedaConsumer.java:207)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.run(SedaConsumer.java:154)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> [na:1.8.0_73]
> at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> [na:1.8.0_73]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_73]
> Caused by: java.nio.channels.ClosedChannelException: null
> at kafka.network.BlockingChannel.send(BlockingChannel.scala:100)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:73)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
>
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at kafka.producer.SyncProducer.send(SyncProducer.scala:113)
> ~[kafka_2.11-0.8.2.2.jar:na]
> at
> kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:58)
> ~[kafka_2.11-0.8.2.2.jar:na]
> ... 24 common frames omitted
>
>
>
> at
>
> org.apache.camel.component.kafka.KafkaProducer.process(KafkaProducer.java:93)
> ~[camel-kafka-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.impl.InterceptSendToEndpoint$1.process(InterceptSendToEndpoint.java:167)
> ~[camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:141)
> ~[camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
> ~[camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163)
> ~[camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:460)
> ~[camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:121)
> [camel-core-2.16.2.jar:2.16.2]
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> org.apache.camel.component.seda.SedaConsumer.sendToConsumers(SedaConsumer.java:298)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.doRun(SedaConsumer.java:207)
> [camel-core-2.16.2.jar:2.16.2]
> at
> org.apache.camel.component.seda.SedaConsumer.run(SedaConsumer.java:154)
> [camel-core-2.16.2.jar:2.16.2]
> at
>
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> [na:1.8.0_73]
> at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> [na:1.8.0_73]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_73]
>
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/camel-Kafka-producer-re-tries-tp5779900.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>
