camel-kafka-connector icon indicating copy to clipboard operation
camel-kafka-connector copied to clipboard

Published 20 hours ago • verified publisher icon apache

ERROR Content is not allowed in prolog

Open sidharthramesh opened this issue 2 years ago • 0 comments

I'm using camel-netty-http-kafka-connector version 3.20.3:

<dependency>
      <groupId>org.apache.camel.kafkaconnector</groupId>
      <artifactId>camel-netty-http-kafka-connector</artifactId>
      <version>3.20.3</version>
      <exclusions>
        <exclusion>
            <groupId>org.slf4j</groupId>
              <artifactId>slf4j-api</artifactId>
          </exclusion>
      </exclusions>
 </dependency>

with Kafka and Kafka Connect version 2.8.2

with the following connector.properties for netty http kafka connector:

name=http-source-2
connector.class=org.apache.camel.kafkaconnector.nettyhttp.CamelNettyhttpSourceConnector
camel.source.path.protocol=http
camel.source.path.host=0.0.0.0
camel.source.pollingConsumerBlockTimeout=0
value.converter=org.apache.kafka.connect.storage.StringConverter
key.converter=org.apache.kafka.connect.storage.StringConverter

Everything works as expected, however there is an error in the logs:

[2023-05-01 22:47:58,599] INFO Apache Camel 3.20.3 (camel-17) is starting (org.apache.camel.impl.engine.AbstractCamelContext:3075)
[2023-05-01 22:47:58,606] INFO Dumping 2 routes as XML (org.apache.camel.impl.DefaultCamelContext:162)
[2023-05-01 22:47:58,642] INFO Apache Camel 3.20.3 (camel-16) is starting (org.apache.camel.impl.engine.AbstractCamelContext:3075)
[2023-05-01 22:47:58,661] INFO Creating shared NettyConsumerExecutorGroup with 17 threads (org.apache.camel.component.netty.NettyComponent:164)
[2023-05-01 22:47:58,664] INFO Dumping 3 routes as XML (org.apache.camel.impl.DefaultCamelContext:162)
[2023-05-01 22:47:59,856] ERROR Content is not allowed in prolog. (org.apache.camel.converter.jaxp.XmlConverter:1128)
org.xml.sax.SAXParseException; lineNumber: 1; columnNumber: 1; Content is not allowed in prolog.
       at java.xml/com.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.createSAXParseException(ErrorHandlerWrapper.java:204)
       at java.xml/com.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.fatalError(ErrorHandlerWrapper.java:178)
       at java.xml/com.sun.org.apache.xerces.internal.impl.XMLErrorReporter.reportError(XMLErrorReporter.java:400)
       at java.xml/com.sun.org.apache.xerces.internal.impl.XMLErrorReporter.reportError(XMLErrorReporter.java:327)
       at java.xml/com.sun.org.apache.xerces.internal.impl.XMLScanner.reportFatalError(XMLScanner.java:1465)
       at java.xml/com.sun.org.apache.xerces.internal.impl.XMLDocumentScannerImpl$PrologDriver.next(XMLDocumentScannerImpl.java:978)
       at java.xml/com.sun.org.apache.xerces.internal.impl.XMLDocumentScannerImpl.next(XMLDocumentScannerImpl.java:605)
       at java.xml/com.sun.org.apache.xerces.internal.impl.XMLNSDocumentScannerImpl.next(XMLNSDocumentScannerImpl.java:112)
       at java.xml/com.sun.org.apache.xerces.internal.impl.XMLDocumentFragmentScannerImpl.scanDocument(XMLDocumentFragmentScannerImpl.java:542)
       at java.xml/com.sun.org.apache.xerces.internal.parsers.XML11Configuration.parse(XML11Configuration.java:889)
       at java.xml/com.sun.org.apache.xerces.internal.parsers.XML11Configuration.parse(XML11Configuration.java:825)
       at java.xml/com.sun.org.apache.xerces.internal.parsers.XMLParser.parse(XMLParser.java:141)
       at java.xml/com.sun.org.apache.xerces.internal.parsers.DOMParser.parse(DOMParser.java:247)
       at java.xml/com.sun.org.apache.xerces.internal.jaxp.DocumentBuilderImpl.parse(DocumentBuilderImpl.java:342)
       at org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(XmlConverter.java:723)
       at org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(XmlConverter.java:709)
       at org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(XmlConverter.java:736)
       at org.apache.camel.xml.jaxb.JaxbHelper.modelToXml(JaxbHelper.java:208)
       at org.apache.camel.xml.jaxb.JaxbModelToXMLDumper.dumpModelAsXml(JaxbModelToXMLDumper.java:230)
       at org.apache.camel.impl.DefaultCamelContext.doDumpRoutes(DefaultCamelContext.java:167)
       at org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:3427)
       at org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:3103)
       at org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:3058)
       at org.apache.camel.support.service.BaseService.start(BaseService.java:119)
       at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2707)
       at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:262)
       at org.apache.camel.main.SimpleMain.doStart(SimpleMain.java:43)
       at org.apache.camel.support.service.BaseService.start(BaseService.java:119)
       at org.apache.camel.kafkaconnector.CamelSourceTask.start(CamelSourceTask.java:180)
       at org.apache.kafka.connect.runtime.WorkerSourceTask.initializeAndStart(WorkerSourceTask.java:231)
       at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:186)
       at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:237)
       at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
       at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
       at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
       at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
       at java.base/java.lang.Thread.run(Thread.java:833)
[2023-05-01 22:47:59,856] ERROR Content is not allowed in prolog. (org.apache.camel.converter.jaxp.XmlConverter:1128)
org.xml.sax.SAXParseException; lineNumber: 1; columnNumber: 1; Content is not allowed in prolog.
       at java.xml/com.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.createSAXParseException(ErrorHandlerWrapper.java:204)
       at java.xml/com.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.fatalError(ErrorHandlerWrapper.java:178)
       at java.xml/com.sun.org.apache.xerces.internal.impl.XMLErrorReporter.reportError(XMLErrorReporter.java:400)
       at java.xml/com.sun.org.apache.xerces.internal.impl.XMLErrorReporter.reportError(XMLErrorReporter.java:327)
       at java.xml/com.sun.org.apache.xerces.internal.impl.XMLScanner.reportFatalError(XMLScanner.java:1465)
       at java.xml/com.sun.org.apache.xerces.internal.impl.XMLDocumentScannerImpl$PrologDriver.next(XMLDocumentScannerImpl.java:978)
       at java.xml/com.sun.org.apache.xerces.internal.impl.XMLDocumentScannerImpl.next(XMLDocumentScannerImpl.java:605)
       at java.xml/com.sun.org.apache.xerces.internal.impl.XMLNSDocumentScannerImpl.next(XMLNSDocumentScannerImpl.java:112)
       at java.xml/com.sun.org.apache.xerces.internal.impl.XMLDocumentFragmentScannerImpl.scanDocument(XMLDocumentFragmentScannerImpl.java:542)
       at java.xml/com.sun.org.apache.xerces.internal.parsers.XML11Configuration.parse(XML11Configuration.java:889)
       at java.xml/com.sun.org.apache.xerces.internal.parsers.XML11Configuration.parse(XML11Configuration.java:825)
       at java.xml/com.sun.org.apache.xerces.internal.parsers.XMLParser.parse(XMLParser.java:141)
       at java.xml/com.sun.org.apache.xerces.internal.parsers.DOMParser.parse(DOMParser.java:247)
       at java.xml/com.sun.org.apache.xerces.internal.jaxp.DocumentBuilderImpl.parse(DocumentBuilderImpl.java:342)
       at org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(XmlConverter.java:723)
       at org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(XmlConverter.java:709)
       at org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(XmlConverter.java:736)
       at org.apache.camel.xml.jaxb.JaxbHelper.modelToXml(JaxbHelper.java:208)
       at org.apache.camel.xml.jaxb.JaxbModelToXMLDumper.dumpModelAsXml(JaxbModelToXMLDumper.java:230)
       at org.apache.camel.impl.DefaultCamelContext.doDumpRoutes(DefaultCamelContext.java:167)
       at org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:3427)
       at org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:3103)
       at org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:3058)
       at org.apache.camel.support.service.BaseService.start(BaseService.java:119)
       at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2707)
       at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:262)
       at org.apache.camel.main.SimpleMain.doStart(SimpleMain.java:43)
       at org.apache.camel.support.service.BaseService.start(BaseService.java:119)
       at org.apache.camel.kafkaconnector.CamelSinkTask.start(CamelSinkTask.java:152)
       at org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:309)
       at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:186)
       at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:237)
       at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
       at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
       at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
       at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
       at java.base/java.lang.Thread.run(Thread.java:833)
[2023-05-01 22:47:59,889] WARN Error dumping routes to XML due to Error during type conversion from type: java.lang.String to the required type: org.w3c.dom.Document with value [#document: null] due to org.xml.sax.SAXParseException: Content is not allowed in prolog.. This exception is ignored. (org.apache.camel.impl.DefaultCamelContext:174)
org.apache.camel.TypeConversionException: Error during type conversion from type: java.lang.String to the required type: org.w3c.dom.Document with value [#document: null] due to org.xml.sax.SAXParseException: Content is not allowed in prolog.
       at org.apache.camel.xml.jaxb.JaxbHelper.modelToXml(JaxbHelper.java:210)
       at org.apache.camel.xml.jaxb.JaxbModelToXMLDumper.dumpModelAsXml(JaxbModelToXMLDumper.java:230)
       at org.apache.camel.impl.DefaultCamelContext.doDumpRoutes(DefaultCamelContext.java:167)
       at org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:3427)
       at org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:3103)
       at org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:3058)
       at org.apache.camel.support.service.BaseService.start(BaseService.java:119)
       at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2707)
       at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:262)
       at org.apache.camel.main.SimpleMain.doStart(SimpleMain.java:43)
       at org.apache.camel.support.service.BaseService.start(BaseService.java:119)
       at org.apache.camel.kafkaconnector.CamelSinkTask.start(CamelSinkTask.java:152)
       at org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:309)
       at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:186)
       at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:237)
       at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
       at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
       at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
       at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
       at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: org.xml.sax.SAXParseException; lineNumber: 1; columnNumber: 1; Content is not allowed in prolog.
       at java.xml/com.sun.org.apache.xerces.internal.parsers.DOMParser.parse(DOMParser.java:262)
       at java.xml/com.sun.org.apache.xerces.internal.jaxp.DocumentBuilderImpl.parse(DocumentBuilderImpl.java:342)
       at org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(XmlConverter.java:723)
       at org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(XmlConverter.java:709)
       at org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(XmlConverter.java:736)
       at org.apache.camel.xml.jaxb.JaxbHelper.modelToXml(JaxbHelper.java:208)
       ... 19 more
[2023-05-01 22:47:59,889] WARN Error dumping routes to XML due to Error during type conversion from type: java.lang.String to the required type: org.w3c.dom.Document with value [#document: null] due to org.xml.sax.SAXParseException: Content is not allowed in prolog.. This exception is ignored. (org.apache.camel.impl.DefaultCamelContext:174)
org.apache.camel.TypeConversionException: Error during type conversion from type: java.lang.String to the required type: org.w3c.dom.Document with value [#document: null] due to org.xml.sax.SAXParseException: Content is not allowed in prolog.
       at org.apache.camel.xml.jaxb.JaxbHelper.modelToXml(JaxbHelper.java:210)
       at org.apache.camel.xml.jaxb.JaxbModelToXMLDumper.dumpModelAsXml(JaxbModelToXMLDumper.java:230)
       at org.apache.camel.impl.DefaultCamelContext.doDumpRoutes(DefaultCamelContext.java:167)
       at org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:3427)
       at org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:3103)
       at org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:3058)
       at org.apache.camel.support.service.BaseService.start(BaseService.java:119)
       at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2707)
       at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:262)
       at org.apache.camel.main.SimpleMain.doStart(SimpleMain.java:43)
       at org.apache.camel.support.service.BaseService.start(BaseService.java:119)
       at org.apache.camel.kafkaconnector.CamelSourceTask.start(CamelSourceTask.java:180)
       at org.apache.kafka.connect.runtime.WorkerSourceTask.initializeAndStart(WorkerSourceTask.java:231)
       at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:186)
       at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:237)
       at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
       at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
       at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
       at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
       at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: org.xml.sax.SAXParseException; lineNumber: 1; columnNumber: 1; Content is not allowed in prolog.
       at java.xml/com.sun.org.apache.xerces.internal.parsers.DOMParser.parse(DOMParser.java:262)
       at java.xml/com.sun.org.apache.xerces.internal.jaxp.DocumentBuilderImpl.parse(DocumentBuilderImpl.java:342)
       at org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(XmlConverter.java:723)
       at org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(XmlConverter.java:709)
       at org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(XmlConverter.java:736)
       at org.apache.camel.xml.jaxb.JaxbHelper.modelToXml(JaxbHelper.java:208)
       ... 19 more
[2023-05-01 22:47:59,890] INFO Dumping 7 route templates as XML (org.apache.camel.impl.DefaultCamelContext:198)
[2023-05-01 22:47:59,891] INFO Dumping 7 route templates as XML (org.apache.camel.impl.DefaultCamelContext:198)
[2023-05-01 22:47:59,950] INFO 

<routeTemplates xmlns="http://camel.apache.org/schema/spring">

   <routeTemplate customId="true" id="ckcMarshal">
       <templateParameter defaultValue="dummyDataformat" name="marshal"/>
       <route>
           <from uri="kamelet:source"/>
           <marshal>
               <custom ref="{{marshal}}"/>
           </marshal>
           <to uri="kamelet:sink"/>
       </route>
   </routeTemplate>

   <routeTemplate customId="true" id="ckcUnMarshal">
       <templateParameter defaultValue="dummyDataformat" name="unmarshal"/>
       <route>
           <from uri="kamelet:source"/>
           <marshal>
               <custom ref="{{unmarshal}}"/>
           </marshal>
           <to uri="kamelet:sink"/>
       </route>
   </routeTemplate>

   <routeTemplate customId="true" id="ckcAggregator">
       <templateParameter defaultValue="aggregate" name="aggregationStrategy"/>
       <templateParameter defaultValue="1" name="aggregationSize"/>
       <templateParameter defaultValue="9223372036854775807" name="aggregationTimeout"/>
       <route>
           <from uri="kamelet:source"/>
           <aggregate aggregationStrategy="{{aggregationStrategy}}" completionSize="{{aggregationSize}}" completionTimeout="{{aggregationTimeout}}" completionTimeoutCheckerInterval="1000">
               <correlationExpression>
                   <expressionDefinition/>
               </correlationExpression>
               <to uri="kamelet:sink"/>
           </aggregate>
       </route>
   </routeTemplate>

   <routeTemplate customId="true" id="ckcIdempotent">
       <templateParameter defaultValue="dummyExpression" name="idempotentExpression"/>
       <templateParameter defaultValue="ckcIdempotentRepository" name="idempotentRepository"/>
       <route>
           <from uri="kamelet:source"/>
           <idempotentConsumer idempotentRepository="{{idempotentRepository}}">
               <simple>{{idempotentExpression}}</simple>
               <to uri="kamelet:sink"/>
           </idempotentConsumer>
       </route>
   </routeTemplate>

   <routeTemplate customId="true" id="ckcRemoveHeader">
       <templateParameter defaultValue="(?!)" name="headersExcludePattern"/>
       <route>
           <from uri="kamelet://source?routeId=ckcRemoveHeader-3"/>
           <removeHeaders id="removeHeaders1" pattern="{{headersExcludePattern}}"/>
           <to id="to1" uri="kamelet://sink?routeId=ckcRemoveHeader-3"/>
       </route>
   </routeTemplate>

   <routeTemplate customId="true" id="ckcSource">
       <templateParameter name="fromUrl"/>
       <templateParameter defaultValue="ckcErrorHandler" name="errorHandler"/>
       <route errorHandlerRef="ckcErrorHandler">
           <from uri="{{fromUrl}}"/>
           <to uri="kamelet:sink"/>
       </route>
   </routeTemplate>

   <routeTemplate customId="true" id="ckcSink">
       <templateParameter name="toUrl"/>
       <templateParameter defaultValue="ckcErrorHandler" name="errorHandler"/>
       <route errorHandlerRef="ckcErrorHandler">
           <from uri="kamelet:source"/>
           <to uri="{{toUrl}}"/>
       </route>
   </routeTemplate>

</routeTemplates>
(org.apache.camel.impl.DefaultCamelContext:208)
[2023-05-01 22:47:59,950] INFO 

<routeTemplates xmlns="http://camel.apache.org/schema/spring">

   <routeTemplate customId="true" id="ckcMarshal">
       <templateParameter defaultValue="dummyDataformat" name="marshal"/>
       <route>
           <from uri="kamelet:source"/>
           <marshal>
               <custom ref="{{marshal}}"/>
           </marshal>
           <to uri="kamelet:sink"/>
       </route>
   </routeTemplate>

   <routeTemplate customId="true" id="ckcUnMarshal">
       <templateParameter defaultValue="dummyDataformat" name="unmarshal"/>
       <route>
           <from uri="kamelet:source"/>
           <marshal>
               <custom ref="{{unmarshal}}"/>
           </marshal>
           <to uri="kamelet:sink"/>
       </route>
   </routeTemplate>

   <routeTemplate customId="true" id="ckcAggregator">
       <templateParameter defaultValue="aggregate" name="aggregationStrategy"/>
       <templateParameter defaultValue="1" name="aggregationSize"/>
       <templateParameter defaultValue="9223372036854775807" name="aggregationTimeout"/>
       <route>
           <from uri="kamelet:source"/>
           <aggregate aggregationStrategy="{{aggregationStrategy}}" completionSize="{{aggregationSize}}" completionTimeout="{{aggregationTimeout}}" completionTimeoutCheckerInterval="1000">
               <correlationExpression>
                   <expressionDefinition/>
               </correlationExpression>
               <to uri="kamelet:sink"/>
           </aggregate>
       </route>
   </routeTemplate>

   <routeTemplate customId="true" id="ckcIdempotent">
       <templateParameter defaultValue="dummyExpression" name="idempotentExpression"/>
       <templateParameter defaultValue="ckcIdempotentRepository" name="idempotentRepository"/>
       <route>
           <from uri="kamelet:source"/>
           <idempotentConsumer idempotentRepository="{{idempotentRepository}}">
               <simple>{{idempotentExpression}}</simple>
               <to uri="kamelet:sink"/>
           </idempotentConsumer>
       </route>
   </routeTemplate>

   <routeTemplate customId="true" id="ckcRemoveHeader">
       <templateParameter defaultValue="(?!)" name="headersExcludePattern"/>
       <route>
           <from uri="kamelet://source?routeId=ckcRemoveHeader-2"/>
           <removeHeaders id="removeHeaders2" pattern="{{headersExcludePattern}}"/>
           <to id="to3" uri="kamelet://sink?routeId=ckcRemoveHeader-2"/>
       </route>
   </routeTemplate>

   <routeTemplate customId="true" id="ckcSource">
       <templateParameter name="fromUrl"/>
       <templateParameter defaultValue="ckcErrorHandler" name="errorHandler"/>
       <route errorHandlerRef="ckcErrorHandler">
           <from uri="{{fromUrl}}"/>
           <to id="to2" uri="kamelet://sink?routeId=ckcSource-1"/>
       </route>
   </routeTemplate>

   <routeTemplate customId="true" id="ckcSink">
       <templateParameter name="toUrl"/>
       <templateParameter defaultValue="ckcErrorHandler" name="errorHandler"/>
       <route errorHandlerRef="ckcErrorHandler">
           <from uri="kamelet:source"/>
           <to uri="{{toUrl}}"/>
       </route>
   </routeTemplate>

</routeTemplates>
(org.apache.camel.impl.DefaultCamelContext:208)
[2023-05-01 22:47:59,977] INFO Routes startup (started:2) (org.apache.camel.impl.engine.AbstractCamelContext:3237)
[2023-05-01 22:47:59,978] INFO     Started route2 (direct://start) (org.apache.camel.impl.engine.AbstractCamelContext:3242)
[2023-05-01 22:47:59,980] INFO     Started ckcRemoveHeader-3 (kamelet://source) (org.apache.camel.impl.engine.AbstractCamelContext:3242)
[2023-05-01 22:47:59,982] INFO Apache Camel 3.20.3 (camel-17) started in 1s509ms (build:1ms init:127ms start:1s381ms) (org.apache.camel.impl.engine.AbstractCamelContext:3266)
[2023-05-01 22:47:59,987] INFO CamelSinkTask connector task started (org.apache.camel.kafkaconnector.CamelSinkTask:157)
[2023-05-01 22:47:59,990] INFO WorkerSinkTask{id=http-sink-0} Sink task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask:310)
[2023-05-01 22:47:59,991] INFO WorkerSinkTask{id=http-sink-0} Executing sink task (org.apache.kafka.connect.runtime.WorkerSinkTask:196)
[2023-05-01 22:48:00,039] INFO [Consumer clientId=connector-consumer-http-sink-0, groupId=connect-http-sink] Resetting the last seen epoch of partition http-calls-to-discharge-0 to 0 since the associated topicId changed from null to vpWRTefSSxGZJ2xGyOnmTA (org.apache.kafka.clients.Metadata:401)
[2023-05-01 22:48:00,046] INFO [Consumer clientId=connector-consumer-http-sink-0, groupId=connect-http-sink] Cluster ID: 5WlLLJZsS1CfeHaZkLD2-w (org.apache.kafka.clients.Metadata:287)
[2023-05-01 22:48:00,049] INFO [Consumer clientId=connector-consumer-http-sink-0, groupId=connect-http-sink] Discovered group coordinator localhost:9092 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:850)

sidharthramesh avatar May 01 '23 17:05 sidharthramesh