如何查询由KafkaSinkConnector创建的PostgreSQL表？

1. 在PostgreSQL中创建一个数据库和一个表

首先，在PostgreSQL中创建一个数据库和一个表。可以使用以下命令在命令行界面上创建：

CREATE DATABASE my_database; CREATE TABLE my_table ( id SERIAL PRIMARY KEY, message VARCHAR NOT NULL );

2. 安装jdbc驱动并在链接中包含依赖项

其次，需要安装Java JDBC驱动程序并将其包含在类路径中。要安装驱动程序，请在Maven或Gradle中添加以下依赖项：

Maven:

<dependency> <groupId>org.postgresql</groupId> <artifactId>postgresql</artifactId> <version>9.4-1201-jdbc4</version> </dependency>

Gradle:

compile 'org.postgresql:postgresql:9.4-1201-jdbc4'

3. 编写Java代码并查询表格

接下来，编写Java代码来查询表格。以下是一个示例：

import java.sql.*;

public class QueryTable { public static void main(String[] args) throws SQLException { Connection connection = DriverManager.getConnection("jdbc:postgresql://localhost:5432/my_database", "user", "password"); PreparedStatement statement = connection.prepareStatement("SELECT * FROM my_table"); ResultSet resultSet = statement.executeQuery(); while (resultSet.next()) { int id = resultSet.getInt("id"); String message = resultSet.getString("message"); System.out.println("ID: " + id + "\nMessage: " + message + "\n"); } resultSet.close(); statement.close(); connection.close(); } }

在这个示例中，首先创建了一个数据库连接，然后使用预备语句（prepared statement）查询表格。结果集（Result Set）随后用于存储查询结果。最后，使用 while 循环遍历结果集，并打印每一行的 id 和 message 值。

4. 运行Java程序

最后，运行 Java 程序，即可查询由 Kafka Sink Connector 创建的 PostgreSQL 表格。