KafkaJDBCsink-是否有方法将Kafka主题值存储为表格中的一个列值？

可以使用Kafka Connect JDBC插件将Kafka主题中的数据写入关系型数据库中。使用JDBC sink连接器时，可以使用以下配置指定表格中的列：

name=jdbc-sink
connector.class=io.confluent.connect.jdbc.JdbcSinkConnector
tasks.max=1
topics=my-topic

# JDBC连接器配置
# 请根据自己的数据库和连接信息进行更改
connection.url=jdbc:mysql://localhost:3306/my-db
connection.user=my-user
connection.password=my-password
dialect.name=MySqlDatabaseDialect

# 要插入的表名
auto.create=true
table.name.format=table1
insert.mode=insert

# 要插入的列，使用${topic}引用主题的值
# 这将创建一个名为'topic_value'的列，并填充主题中的值
# 您可以根据需要更改列名称
# 更多信息请参考官方文档：https://docs.confluent.io/kafka-connect-jdbc/current/sink-connector/sink_config_options.html
transforms=ValueField
transforms.ValueField.type=org.apache.kafka.connect.transforms.ReplaceField$Value
transforms.ValueField.renames=.*(value).*:topic_value

上述配置中，使用transforms将Kafka主题中的值替换为'topic_value'，然后将其插入到指定的表格中。这样，数据库表格中的'topic_value'列值将被设置为Kafka主题中的值。

参考文献：

• https://docs.confluent.io/kafka-connect-jdbc/current/sink-connector/sink_config_options.html
• https://docs.confluent.io/kafka-connect-jdbc/current/index.html