【Kafka】Kafka Connect ～ DB/Schema切替 ～

■ はじめに

小ネタ。
Apache KafkaでDB/Schemaを切り替える方法についてメモ。

【１】KafkaでDB/Schemaを切り替えるには

* Topic を [DB].[Schema].[Table] のようにする

【２】影響する点

１）Kafkaの設定

topics

# topics=db_name # 修正前
#  topics=[DB].[Schema].[Table]
topics=db_name.schema_name.table_name

２）呼び出し先・後

Producer の場合

# future = producer.send('table_name', value=value, key=key) # 修正前
 future = producer.send('db_name.schema_name.table_name', value=value, key=key)

関連記事

Apache Kafka ～ 基礎知識編 ～
https://dk521123.hatenablog.com/entry/2023/04/26/103421
Apache Kafka ～ 入門編 ～
https://dk521123.hatenablog.com/entry/2023/05/01/000000
Kafka Connect ～ 環境構築編 ～
https://dk521123.hatenablog.com/entry/2023/10/22/220717
kafka-python ～ 入門編 ～
https://dk521123.hatenablog.com/entry/2023/10/24/000309