Разъем JDBC Kafka не принимает новые коммиты

apache-kafka

178 просмотра

1 ответ

1 Репутация автора

В настоящее время я использую соединитель JDBC Kafka для опроса записей из базы данных Oracle. Свойства коннектора настроены на использование режима отметки времени, и мы предоставили простой запрос на выборку в свойствах (не используя предложение where) - исходя из моего понимания, это должно работать.

Однако в настоящее время при создании экземпляра соединителя я вижу, что первоначальный запрос извлекает все записи, которые он должен, и публикует их для потребителя Kafka - но любые новые коммиты в oracle db не регистрируются, и соединитель просто опрашивается, не находя любая новая информация и поддержание ее смещения.

В коннекторе нет исключений, и нет никаких признаков проблемы, кроме того, что он не получает новые коммиты в БД.

Одна вещь, которую я не смог доказать, имеет значение, это то, что все поля в dracle db все обнуляются. Но я проверил изменение этого значения для поля метки времени, и это не имело никакого эффекта, и то же поведение продолжалось. Я также проверил в массовом режиме, и он отлично работает и получает новые коммиты, хотя я не могу использовать массовый режим, так как мы не можем дублировать записи для системы.

Кто-нибудь имеет какие-либо идеи, почему разъем не может получать новые коммиты для режима метки времени?

Автор: AutomationUser Источник Размещён: 17.07.2016 09:32

Ответы (1)


0 плюса

1565 Репутация автора

Как выглядит ваш файл свойств? Вы должны убедиться, что используете увеличивающийся столбец или столбец отметки времени. Если вы используете столбец метки времени, обновляется ли он при фиксации? Что касается нулей, вы можете настроить свой запрос, чтобы объединить нулевой столбец со значением. В качестве альтернативы, я думаю, что есть настройка, позволяющая обнулять столбцы.

Автор: mike01010 Размещён: 08.05.2017 09:49
Вопросы из категории :
32x32