Блог

Главная - Вопросы по программированию - Измените имя темы, используемое соединителем Debezium

Измените имя темы, используемое соединителем Debezium

#apache-kafka #apache-kafka-connect #debezium

Вопрос:

Я хотел бы изменить имена тем с помощью соединителя Debezium, так как я хотел бы, чтобы темы не назывались именем по умолчанию «server.schema.table».

Ответ №1:

Вы можете использовать различные преобразования Kafka Connect для настройки имени темы.

  • InsertField чтобы задать статическое имя темы
  • ExtractField ExtractTopic за использование какого — либо свойства записи
  • RegexRouter для изменения названия темы на основе шаблона ; например, удаление server.schema. префикса
  • Один из твоих собственных

Комментарии:

1. я использую ksql, какие строки кода я должен добавить в создание соединителя, чтобы имя sm2.ingestion.surf.db.TableName использовалось в качестве имени по умолчанию для создания темы?

2. Не могли бы вы, пожалуйста, показать конфигурацию вашего разъема в своем вопросе? Ksql встраивает соединение. transforms является свойством соединителя. Тип поля вставки задает статическое имя темы… Пройдите по ссылкам для примеров

3. Или , если вы пытаетесь добавить префикс имени базы sm2.ingestion.surf данных, используйте RegexRouter

Метки: ,