Производитель Kafka не может создавать темы и постоянно выдает ошибку после создания соединителя Debezium MySQL

Я использую Debezium в качестве инструмента CDC для потоковой передачи данных из MySql. После установки соединителя Debezium MySQL в кластер Confluent OSS я пытаюсь зафиксировать изменения MySQL bin_log в теме Kafka. Когда я создаю коннектор, после создания моментального снимка базы данных я получаю непрерывную серию ошибок.

Я проверил, что MySql bin_log включен, и попытался перезапустить реестр схемы и соединители с разными сериализаторами. Но я получаю те же ошибки.

Журналы ошибок показывают:

[2019-06-21 13:56:14,885] INFO Step 8: - Completed scanning a total of 955 rows from table 'mydb.test' after 00:00:00.086 (io.debezium.connector.mysql.SnapshotReader:565)
[2019-06-21 13:56:14,886] INFO Step 8: scanned 1758 rows in 2 tables in 00:00:00.383 (io.debezium.connector.mysql.SnapshotReader:601)
[2019-06-21 13:56:14,886] INFO Step 9: committing transaction (io.debezium.connector.mysql.SnapshotReader:635)
[2019-06-21 13:56:14,887] INFO Completed snapshot in 00:00:01.055 (io.debezium.connector.mysql.SnapshotReader:701)
[2019-06-21 13:56:14,965] WARN [Producer clientId=producer-5] Error while fetching metadata with correlation id 11: {kbserver=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:968)
[2019-06-21 13:56:15,066] WARN [Producer clientId=producer-5] Error while fetching metadata with correlation id 12: {kbserver=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:968)
[2019-06-21 13:56:15,168] WARN [Producer clientId=producer-5] Error while fetching metadata with correlation id 13: {kbserver=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:968)
[2019-06-21 13:56:15,269] WARN [Producer clientId=producer-5] Error while fetching metadata with correlation id 14: {kbserver=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:968)
[2019-06-21 13:56:15,370] WARNDebezium [Producer clientId=producer-5] Error while fetching metadata with correlation id 15: {kbserver=UNKNOWN_TOPIC_OR_PARTITION}

Полезная нагрузка соединителя, которую я отправляю, выглядит следующим образом:

{
 "name": "debezium-connector",
 "config": {
 "connector.class": "io.debezium.connector.mysql.MySqlConnector",
 "tasks.max": "1",
 "key.serializer": "io.confluent.connect.avro.AvroConverter",
 "value.serializer": "io.confluent.connect.avro.AvroConverter",
 "database.hostname": "localhost",
 "database.port": "3306",
 "database.user": "test",
 "database.password": "test@123",
 "database.whitelist": "mydb",
 "table.whitelist": "mydb.test",
 "database.server.id": "1",
 "database.server.name": "kbserver",
 "database.history.kafka.bootstrap.servers": "kafka:9092",
 "database.history.kafka.topic": "db-schema.mydb",
 "include.schema.changes": "true"
 }
 }

кто-нибудь знает, почему это происходит или как я могу это исправить?

Решение проблемы

пожалуйста, обратитесь к database.whitelistи table.whitelist. Они непоследовательны.

Это должно быть или mydbи mydb.testили dbи db.testв зависимости от имени базы данных.