Как установить offset.commit.policy в AlwaysCommitOffsetPolicy в дебезиуме?

Question

Я создал движок Debezium Embedded для сбора данных изменений MySQL.Я хочу зафиксировать смещения, как только смогу.В коде создается конфигурация, включающая в себя следующее.

.with("offset.commit.policy",OffsetCommitPolicy.AlwaysCommitOffsetPolicy.class.getName())

Запуск этого возврата, java.lang.NoSuchMethodException: io.debezium.embedded.spi.OffsetCommitPolicy$AlwaysCommitOffsetPolicy.<init>(io.debezium.config.Configuration)

Однако, когда я запускаю встроенный движок с помощью .with("offset.commit.policy",OffsetCommitPolicy.PeriodicCommitOffsetPolicy.class.getName()), встроенный двигатель работает нормально.

Обратите внимание, что конструктор класса OffsetCommitPolicy.PeriodicCommitOffsetPolicy включает параметр config, а OffsetCommitPolicy.AlwaysCommitOffsetPolicy - нет.

public PeriodicCommitOffsetPolicy(Configuration config) { ... }

Как использовать встроенный движок debezium для использованияего AlwaysCommitOffsetPolicy?

Answer 1

Спасибо за отчет.Это частично ошибка (которую мы будем благодарны, если вы сможете войти в нашу Jira).Вы можете решить эту проблему, вызвав встроенный построитель встроенных механизмов, например, `io.debezium.embedded.EmbeddedEngine.create (). With (OffsetCommitPolicy.always ()) '