[
https://issues.apache.org/jira/browse/CAMEL-12076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16290628#comment-16290628
]
ASF GitHub Bot commented on CAMEL-12076:
----------------------------------------
dmvolod opened a new pull request #2147: CAMEL-12076: Specified topic is
ignored when KafkaConfiguration is used
URL: https://github.com/apache/camel/pull/2147
If topic property was not received from configuration or header parameters
take it from the remaining URI. Also some minor code style fixes are applied.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
> Camel Kafka producer: Specified topic is ignored ("No topic key set" error)
> when KafkaConfiguration is used
> -----------------------------------------------------------------------------------------------------------
>
> Key: CAMEL-12076
> URL: https://issues.apache.org/jira/browse/CAMEL-12076
> Project: Camel
> Issue Type: Bug
> Components: camel-kafka
> Affects Versions: 2.20.1
> Reporter: Igor Lavrentjev
> Assignee: Dmitry Volodin
>
> Specified topic is ignored ("No topic key set" error) when KafkaConfiguration
> is used. When topic is set inside KafkaConfiguration then no error occurs.
> <spring-boot.version>1.5.8.RELEASE</spring-boot.version>
> <camel.version>2.20.1</camel.version>
> {code}
> from("direct:sendToKafka")
> .setBody(constant("Message from Camel to Kafka"))
> .setHeader(KafkaConstants.KEY, constant("Camel"))
> .to("kafka:TESTTOPIC?configuration=#kafkaConfiguration");
> {code}
> {code}
> 2017-12-11 14:16:35.466 ERROR 12048 --- [ad #1 - WireTap] CamelRouter
> : Exchange[ExchangePattern: InOnly, BodyType: String,
> Body: Message from Camel to Kafka, CaughtExceptionType:
> org.apache.camel.CamelExchangeException, CaughtExcept
> ionMessage: No topic key set. Exchange[ID-5CG7383K6H00BA-1512994577303-0-3],
> StackTrace: org.apache.camel.CamelExchangeException: No topic key set.
> Exchange[ID-5CG7383K6H00BA-1512994577303-0-3]
> at
> org.apache.camel.component.kafka.KafkaProducer.createRecorder(KafkaProducer.java:149)
> at
> org.apache.camel.component.kafka.KafkaProducer.process(KafkaProducer.java:251)
> at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:148)
> at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:548)
> at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:138)
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:101)
> at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
> at
> org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:62)
> at
> org.apache.camel.processor.SendDynamicProcessor$1.doInAsyncProducer(SendDynamicProcessor.java:132)
> at
> org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:445)
> at
> org.apache.camel.processor.SendDynamicProcessor.process(SendDynamicProcessor.java:127)
> at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:548)
> at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
> at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:97)
> at
> org.apache.camel.processor.WireTapProcessor$1.call(WireTapProcessor.java:158)
> at
> org.apache.camel.processor.WireTapProcessor$1.call(WireTapProcessor.java:153)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> ]
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
