Соединитель Debezium MySQL настроен и работает правильно, но когда я создаю поток или таблицу в KSQL на основе темы, все значения столбцов возвращаются как нулевые.
Я знаю, что разъем в основном работает, потому что...
$ confluent consume dbbi.bi.clients --value-format avro --from-beginning
... предоставляет прекрасный список клиентов в консоли (здесь не показан, но он правильно отформатирован в формате json с ожидаемыми значениями). Далее пробую создать таблицу (или поток - не важно) в ksql:
CREATE TABLE tbl_clients (id, appname STRING) WITH (KAFKA_TOPIC='dbbi.bi.clients', VALUE_FORMAT='AVRO', KEY='id');
Результат:
ksql> select * from tbl_clients;
1563267463214 | [f | null | null
1563267463214 | [h | null | null
1563267463214 | [j | null | null
1563267463214 | [l | null | null
1563267463214 | [n | null | null
1563267463214 | [p | null | null
1563267463214 | [r | null | null
1563267463214 | [t | null | null
1563267463214 | [v | null | null
1563267463214 | [x | null | null
1563267463214 | [z | null | null
1563267463214 | [| | null | null
1563267463214 | [~ | null | null
1563286302233 | [� | null | null
Неважно, какие поля выбраны для таблицы (или потока). Неважно, какая таблица (тема) используется. Значение всех столбцов всегда равно нулю. Излишне говорить, что значения в базе данных не равны нулю.
И последняя деталь: все это находится в Confluent 5.2.2 и Debezium mysql Connector 0.9.4.
Есть идеи для новичка? В противном случае, некоторые подсказки о том, как отлаживать?
