汇合jdbc sink examples.table不存在

7gyucuyw  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(291)

我使用confluent和kafka将kafka主题中的数据下沉到mysql表中。我的配置是

name=jdbc-sink 
connector.class=io.confluent.connect.jdbc.JdbcSinkConnector
tasks.max=1
topics=foobar
connection.url=jdbc:mysql://localhost:3306/demo1
connection.user=user
connection.password=pass
auto.create=true

我在使用命令

./bin/connect-standalone ./etc/schema-registry/connect-avro-standalone.properties ./etc/kafka-connect-jdbc/sink-quickstart-mysql.properties

所以,当foobar表不在demo1数据库中时,它会给出一个错误,即表demo1.foobar不存在。所以当我自己在demo1中创建foobar表时,它的给定错误。

WARN Write of 2 records failed, remainingRetries=10 (io.confluent.connect.jdbc.sink.JdbcSinkTask:77)
java.sql.SQLSyntaxErrorException: Table 'examples.foobar' doesn't exist

我的配置有问题吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题