[
https://issues.apache.org/jira/browse/CAMEL-14420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17020917#comment-17020917
]
Omar Al-Safi commented on CAMEL-14420:
--------------------------------------
Hi [~alexeyshockov], I don't think this is an issue with Debezium. We just
don't pipeline these configurations to debezium, indeed debezium does accept
these configurations and it works perfectly after that. To fix this, we can do
something like what we did in camel-kafka, where we added an additional
parameters {{advance}} that handles any extra configurations that are not
exposed by default.
> Support `KafkaOffsetBackingStore` in camel-debezim
> --------------------------------------------------
>
> Key: CAMEL-14420
> URL: https://issues.apache.org/jira/browse/CAMEL-14420
> Project: Camel
> Issue Type: Bug
> Components: camel-debezium
> Affects Versions: 3.0.0
> Reporter: Omar Al-Safi
> Priority: Minor
> Fix For: 3.x
>
>
> Currently, when set {{offsetStorage}} to {{org.apache.kafka.connect.storage.
> KafkaOffsetBackingStore}} and {{offsetTopic}}, the engine fails with the
> following error:
> {code}
> org.apache.kafka.common.config.ConfigException: Missing required
> configuration "bootstrap.servers" which has no default value.
> at
> org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:476)
> ~[kafka-clients-2.3.1.jar:na]
> at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:466)
> ~[kafka-clients-2.3.1.jar:na]
> at
> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:108)
> ~[kafka-clients-2.3.1.jar:na]
> at
> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:142)
> ~[kafka-clients-2.3.1.jar:na]
> at
> org.apache.kafka.clients.admin.AdminClientConfig.<init>(AdminClientConfig.java:196)
> ~[kafka-clients-2.3.1.jar:na]
> at org.apache.kafka.clients.admin.AdminClient.create(AdminClient.java:65)
> ~[kafka-clients-2.3.1.jar:na]
> at org.apache.kafka.connect.util.TopicAdmin.<init>(TopicAdmin.java:169)
> ~[connect-runtime-2.3.1.jar:na]
> at
> org.apache.kafka.connect.storage.KafkaOffsetBackingStore$1.run(KafkaOffsetBackingStore.java:98)
> ~[connect-runtime-2.3.1.jar:na]
> at
> org.apache.kafka.connect.util.KafkaBasedLog.start(KafkaBasedLog.java:128)
> ~[connect-runtime-2.3.1.jar:na]
> at
> org.apache.kafka.connect.storage.KafkaOffsetBackingStore.start(KafkaOffsetBackingStore.java:109)
> ~[connect-runtime-2.3.1.jar:na]
> at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:733)
> ~[debezium-embedded-0.10.0.Final.jar:0.10.0.Final]
> at
> java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
> ~[na:na]
> at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
> ~[na:na]
> at
> java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
> ~[na:na]
> at
> java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
> ~[na:na]
> at java.base/java.lang.Thread.run(Thread.java:830) ~[na:na]
> {code}
> The reason is that, {{org.apache.kafka.connect.storage.
> KafkaOffsetBackingStore}} is using bootstrap servers set via Kafka Connect
> configs, hence we need to see how we can go around this.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
