我使用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
我的配置有问题吗?
暂无答案!
目前还没有任何答案,快来回答吧!