Please join the Debezium community on Zulip (https://debezium.zulipchat.com). This room is not used any longer.
after Alpha1 is out?
only impact for folks really would be to adjust their own local names to point to main rather than master
Hey everybody, I am receiving NullPointerException on MySQL connector, The issue blocked the whole process on my side. I am not sure if it is a misconfiguration or a bug. I would appreciate any comments on that.
https://issues.redhat.com/browse/DBZ-4166
https://issues.redhat.com/browse/DBZ-4166
Hi @pysf my apologies I didn't see you added the full log to the issue; okay I see the problem; looks like the parsing error allows the connector to proceed due to
database.history.skip.unparseable.ddl=true; so we need to fix the grammar bug you've illustrated, thanks!
That's why you get the NPE
I don't believe normally that's a problem during streaming but I don't think we intended there to be
CREATE TABLE syntax problems during snapshot like we do streaming.
thx!
all, updated the roadmap a bit for Debezium 1.8: https://twitter.com/gunnarmorling/status/1450734810402537475
Hi team, I am getting the below error after whitelisting a new table in mysql connector (version 1.1Final)
org.apache.kafka.connect.errors.ConnectException: Encountered change event for table dominus.payment whose schema isn't known to this connector
at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230)
at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:207)
at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:536)
at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095)
at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943)
at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580)
at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.connect.errors.ConnectException: Encountered change event for table dominus.payment whose schema isn't known to this connector
at io.debezium.connector.mysql.BinlogReader.informAboutUnknownTableIfRequired(BinlogReader.java:794)
at io.debezium.connector.mysql.BinlogReader.handleUpdateTableMetadata(BinlogReader.java:768)
at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:519)
... 5 more@MrTrustworthy you also faced similar issue earlier, what is the resolution here?
2 replies
isn't this supported for MySQL and Oracle now?
I see changes to the Oracle parser, but doc updates only for MySQL
@jpechane speaking of docs, something like
ColumnImpl should neither face up in docs of the actual option nor in actual user docs; it's an implementation detail and no one will know what this is about
@/all Debezium is moving to https://debezium.zulipchat.com Please continue with your discussion topics there as this channel will no longer be monitored.
/all Debezium is moving to https://debezium.zulipchat.com Please continue with your discussion topics there as this channel will no longer be monitored.
test
@jpechane Debezium Community migrated to https://debezium.zulipchat.com/
Test
@jpechane Debezium Community migrated to https://debezium.zulipchat.com/
@gunnarmorling I created a Jira issue for the first time. Does it make sense? https://issues.redhat.com/projects/DBZ/issues/DBZ-4191
1 reply
Hello, the 1.7 and 1.8 version gets :
Error: Could not find or load main class org.apache.kafka.connect.cli.ConnectDistributed
I run with the default config
docker run -it --name connect -p 8083:8083 -e GROUP_ID=1 -e CONFIG_STORAGE_TOPIC=my-connect-configs -e OFFSET_STORAGE_TOPIC=my-connect-offsets -e ADVERTISED_HOST_NAME=192.100.100.100 debezium/connect
what is the wrong?
@gunnarmorling Hi dear, I'm trying to expose metrics of Kafka Connector using this docker-compose file (https://github.com/debezium/debezium-examples/blob/main/monitoring/docker-compose.yml), but I'm confusing myself with this line (KAFKA_OPTS=-javaagent:/kafka/etc/jmx_prometheus_javaagent.jar=8080:/kafka/etc/config.yml). Can you please tell me what I'm supposed to replace here? Btw I can access logs in JConsole but it's neither working in the browser nor in Prometheus without this line.