Kafka：根据主题在单独的列中创建流

Question

我刚刚使用postgres源连接器将我的kafka连接到postgres。现在，当我打印主题时，我得到以下输出：

rowtime: 4/1/20 4:16:12 PM UTC, key: <null>, value: {"userid": 4, "id": 5, "title": "lorem", "body": "dolor sit amet, consectetur"}
rowtime: 4/1/20 4:16:12 PM UTC, key: <null>, value: {"userid": 5, "id": 6, "title": "ipsum", "body": "cupidatat non proident"}

我如何从该主题创建数据流，以便将值分隔为它们自己的列，就像它们最初在数据库表中一样？

奖励问题：在创建源连接器时，是否可以在jdbc-connector中进行指定以将列分为主题？

我的连接器看起来像这样：

curl -X POST http://localhost:8083/connectors -H "Content-Type: application/json" -d '{
        "name": "jdbc_source_postgres_02",
        "config": {
                "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
                "connection.url": "jdbc:postgresql://postgres:5432/kafka",
                "connection.user": "bob",
                "connection.password": "builder",
                "topic.prefix": "post_",
                "mode":"bulk",
                "table.whitelist" : "kafka_t.users_t",
                "poll.interval.ms" : 500
                }
        }'

Answer 1

我如何从该主题创建数据流，以便将值分隔为它们自己的列，就像它们最初在数据库表中一样？