Как позволить debezium начать чтение binlog с последней строки
Я пытаюсь позволить Debezium начать чтение бинарного журнала напрямую из нижней части файла. Может ли кто-нибудь помочь в этом вопросе, пожалуйста?
Построение конвейеров данных в реальном времени с Apache Kafka: Руководство по Python
Apache Kafka - популярная платформа распределенной потоковой передачи данных, которую можно использовать для построения конвейеров данных в реальном...
1
0
508
1
Перейти к ответу
Данный вопрос помечен как решенный
Ответы 1
Ответ принят как подходящий
Судя по документы, вы можете использовать snapshot.mode=schema_only:
If you don’t need the topics to contain a consistent snapshot of the data but only need them to have the changes since the connector was started, you can use the
schema_onlyoption, where the connector only snapshots the schemas (not the data).
Другие вопросы по теме
NodeJS: KafkaJSProtocolError: поддерживаемые протоколы члена группы несовместимы с протоколами существующих участников
Можно ли переименовать поля при запуске соединителя debezium mysql, инициируемом сообщением?
Проблема с выполнением целевого плагина wildfly swarm, несовместимость API, java.lang.AbstractMethodError
Как настроить коннектор Debezium Mysql для создания примитивного ключа вместо объекта struct или json?
Ошибка Debezium MySQL: пароль для подключения пуст
Каково точное значение параметра database.history в Debezium?
Создание потока KSQL на основе Avro из данных Avro Debezium создает странную схему
Не удается подключить Debezium 0.9.2 к SQL Server 2008 R2
Kafka Debezium MariaDB SinkConnector
Debezium Kafka коннектор mongodb
Похожие вопросы
Обеспечивает ли confluent kafka потоковую передачу, группировку и агрегацию в python?
Как filebeat справляется с надежностью при выводе в Kafka?
Данные, считанные из кафки в искру, исчезают после регистрации в виде таблицы?
Как отслеживать отставание потребителя в кафке через jmx?
Как отслеживать строки (по идентификатору) с определенным значением столбца с помощью Kafka JDBC Connector?
Как реализовать свертки временных рядов в Kafka?
Ожидание ответа внутреннего процесса с использованием Spring Boot, Kafka и ReactJS
Должны ли Kafka системы передачи состояния, переносимые событиями, быть реализованы с использованием GlobalKTable для локальных запросов?
Python Producer может отправлять через оболочку, но не .py
Чтение данных, удержание данных в течение N секунд, запись данных (Kafka, Flink)