слияния JDBC-Sink examples.table не существует - PullRequest
Новая
       27

слияния JDBC-Sink examples.table не существует

0 голосов
/ 18 сентября 2018

Я использую 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 не существует. Поэтому, когда я сам создаю таблицу foobar в demo1, она дает ошибку. 

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

Есть ли проблемы с моими конфигурациями?

...