[
https://issues.apache.org/jira/browse/CAMEL-14188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17000106#comment-17000106
]
Omar Al-Safi commented on CAMEL-14188:
--------------------------------------
In order to upgrade debezium to 1.0, Kafka in Camel will need to be upgraded to
2.4.0 as well. The reason is, Kafka connect 2.4.0 uses new attributes the
configDef which is found kafka-client common package. What we have is 2.3.1,
hence the tests fail with this error:
{code}
java.lang.NoClassDefFoundError:
org/apache/kafka/common/config/ConfigDef$CaseInsensitiveValidString
at
org.apache.kafka.connect.json.JsonConverterConfig.<clinit>(JsonConverterConfig.java:64)
at
org.apache.kafka.connect.json.JsonConverter.configure(JsonConverter.java:298)
at
org.apache.kafka.connect.json.JsonConverter.configure(JsonConverter.java:311)
at io.debezium.embedded.EmbeddedEngine.<init>(EmbeddedEngine.java:628)
at io.debezium.embedded.EmbeddedEngine.<init>(EmbeddedEngine.java:69)
at io.debezium.embedded.EmbeddedEngine$2.build(EmbeddedEngine.java:581)
at
org.apache.camel.component.debezium.DebeziumConsumer.createDbzEngine(DebeziumConsumer.java:69)
at
org.apache.camel.component.debezium.DebeziumConsumer.doStart(DebeziumConsumer.java:50)
at
org.apache.camel.support.service.ServiceSupport.start(ServiceSupport.java:117)
at
org.apache.camel.impl.engine.AbstractCamelContext.startService(AbstractCamelContext.java:2892)
at
org.apache.camel.impl.engine.AbstractCamelContext.doStartOrResumeRouteConsumers(AbstractCamelContext.java:3219)
at
org.apache.camel.impl.engine.AbstractCamelContext.doStartRouteConsumers(AbstractCamelContext.java:3153)
at
org.apache.camel.impl.engine.AbstractCamelContext.safelyStartRouteServices(AbstractCamelContext.java:3063)
at
org.apache.camel.impl.engine.AbstractCamelContext.doStartOrResumeRoutes(AbstractCamelContext.java:2828)
at
org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:2632)
at
org.apache.camel.impl.engine.AbstractCamelContext.lambda$doStart$2(AbstractCamelContext.java:2437)
at
org.apache.camel.impl.engine.AbstractCamelContext.doWithDefinedClassLoader(AbstractCamelContext.java:2454)
at
org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2435)
at
org.apache.camel.support.service.ServiceSupport.start(ServiceSupport.java:117)
at
org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2344)
at
org.apache.camel.test.junit4.CamelTestSupport.startCamelContext(CamelTestSupport.java:820)
at
org.apache.camel.test.junit4.CamelTestSupport.doSetUp(CamelTestSupport.java:460)
at
org.apache.camel.test.junit4.CamelTestSupport.setUp(CamelTestSupport.java:336)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
at
com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)
at
com.intellij.rt.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:33)
at
com.intellij.rt.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:230)
at com.intellij.rt.junit.JUnitStarter.main(JUnitStarter.java:58)
Caused by: java.lang.ClassNotFoundException:
org.apache.kafka.common.config.ConfigDef$CaseInsensitiveValidString
at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
... 52 more
{code}
And this {{CaseInsensitiveValidString}} it only exists in kafka-clients 2.4.0.
> Upgrade debezium to 1.0 Final
> -----------------------------
>
> Key: CAMEL-14188
> URL: https://issues.apache.org/jira/browse/CAMEL-14188
> Project: Camel
> Issue Type: Task
> Components: camel-debezium
> Reporter: Claus Ibsen
> Assignee: Omar Al-Safi
> Priority: Major
> Fix For: 3.1.0
>
>
> Lets upgrade to latest release as the current 0.10 release is a very early
> release and its not a 1.0 GA production ready version.
> So IMHO its better to follow the 1.0.x release train and be closer to 1.0 GA
> when it hit the street later
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
