Collectives™ on Stack Overflow
Find centralized, trusted content and collaborate around the technologies you use most.
Learn more about Collectives
Teams
Q&A for work
Connect and share knowledge within a single location that is structured and easy to search.
Learn more about Teams
"name": "source-mariadb-VIEW_GIORGOS",
"config": { "connector.class":"io.confluent.connect.jdbc.JdbcSourceConnector",
"tasks.max":"10",
"connection.url":"jdbc:mariadb://localhost:3306/kafka?user=myuser&password=mypass",
"table.whitelist":"VIEW_GIORGOS",
"mode":"timestamp",
"timestamp.column.name":"ROWVERSION",
"validate.non.null":"false",
"topic.prefix":"GIORGOS-",
"table.types":"TABLE,VIEW",
"poll.interval.ms":"1000",
"consumer.group.id":"mytopicgroup1"
But Kafka Connect reports the following error:
WARN [Producer clientId=producer-8] Got error produce response with correlation id 1504 on topic-partition GIORGOS-VW_GIORGOS, retrying (2147483149 attempts left).
Error: CORRUPT_MESSAGE (org.apache.kafka.clients.producer.internals.Sender:526)
–
Thanks for contributing an answer to Stack Overflow!
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
