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.
