You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by "sidharthramesh (via GitHub)" <gi...@apache.org> on 2023/05/01 17:22:54 UTC
[GitHub] [camel-kafka-connector] sidharthramesh opened a new issue, #1527: ERROR Content is not allowed in prolog
sidharthramesh opened a new issue, #1527:
URL: https://github.com/apache/camel-kafka-connector/issues/1527
I'm using camel-netty-http-kafka-connector version 3.20.3:
```xml
<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:
```properties
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)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@camel.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] ERROR Content is not allowed in prolog [camel-kafka-connector]
Posted by "oscerd (via GitHub) via commits" <co...@camel.apache.org>.
oscerd commented on issue #1527:
URL: https://github.com/apache/camel-kafka-connector/issues/1527#issuecomment-6632229918
Sorry this was never answered. The error came from the XML route dump that Camel 3.20 logged at startup; as the WARN right after it says, it was ignored and did not affect the connector. Route dumping was reworked in Camel 4. In a quick check with the 4.22.0 jars, the default settings do not print a route dump at all, and an explicit XML dump (`camel.main.dumpRoutes=xml`) completes without this error. Closing this as outdated, since 3.20.x is no longer supported; camel-netty-http-kafka-connector is still available in 4.22.x, so if you see this there, please open a new issue with the version, connector config and full log.
---
_Claude Code on behalf of Andrea Cosentino_
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] ERROR Content is not allowed in prolog [camel-kafka-connector]
Posted by "oscerd (via GitHub) via commits" <co...@camel.apache.org>.
oscerd closed issue #1527: ERROR Content is not allowed in prolog
URL: https://github.com/apache/camel-kafka-connector/issues/1527
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org