Mailing-List: contact issues-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@camel.apache.org
Date: Tue, 12 Dec 2017 10:28:00 +0000 (UTC)
From: "Dmitry Volodin (JIRA)" <jira@apache.org>
To: issues@camel.apache.org
Message-ID: <JIRA.13124120.1512995309000.438101.1513074480239@Atlassian.JIRA>
In-Reply-To: <JIRA.13124120.1512995309000@Atlassian.JIRA>
References: <JIRA.13124120.1512995309000@Atlassian.JIRA> <JIRA.13124120.1512995309561@jira-lw-us.apache.org>
Subject: [jira] [Assigned] (CAMEL-12076) Camel Kafka producer: Specified
 topic is ignored ("No topic key set" error) when KafkaConfiguration is used
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Tue, 12 Dec 2017 10:28:09 -0000


     [ https://issues.apache.org/jira/browse/CAMEL-12076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dmitry Volodin reassigned CAMEL-12076:
--------------------------------------

    Assignee: Dmitry Volodin

> 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)