首页 > 解决方案 > 如何在 jdbc 连接器的 kafka 中创建多个主题和多个表?

问题描述

我试图在命令提示符下安装 kafka connect。

我有一个像这样的连接器

name=test-source-oracle-jdbc

connector.class=io.confluent.connect.jdbc.JdbcSourceConnector

tasks.max=1
connection.url=jdbc:oracle:thin:@172.26.70.84:1621/OPICSDEV

connection.user=KFK_USER

connection.password=kafka_user012345

mode=bulk

topic.prefix=opics-demo

query=select * from OPICS.cust where rownum < 5

poll.interval.ms=900000

标签: oraclejdbcapache-kafkaapache-kafka-connect

解决方案


如果要从多个表中读取数据,则需要同时运行多个连接器。

类似地,也可以在不同的连接器属性中提供不同的主题前缀


推荐阅读