Kafka 是一個高性能、低延遲的分布式消息隊列，被廣泛應用于各種實時數據處理場景。而 MySQL 是一種開源的關系型數據庫管理系統，也是大多數企業應用系統的核心組件之一。在實際業務開發中，使用 Kafka 讀取 MySQL 數據是非常常見的需求。

下面我們來介紹一下如何使用 Kafka 連接 MySQL 并讀取數據。

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("acks", "all");
props.put("retries", 0);
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
Producer<String, String> producer = new KafkaProducer<>(props);
String topic = "mysql-topic";
// JDBC 連接配置
String url = "jdbc:mysql://localhost:3306/test";
String user = "root";
String password = "root";
try {
Class.forName("com.mysql.jdbc.Driver");
Connection conn = DriverManager.getConnection(url, user, password);
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM users");
while (rs.next()) {
String id = rs.getString("id");
String name = rs.getString("name");
String message = id + "," + name;
producer.send(new ProducerRecord<>(topic, message));
}
producer.close();
conn.close();
} catch (Exception e) {
e.printStackTrace();
}

以上代碼就是一個簡單的示例，通過 JDBC 連接 MySQL 數據庫，并將數據發送到 Kafka 隊列中。

通過上面的代碼片段，我們可以看到在 Java 代碼中同時使用了 Kafka 的生產者和 JDBC 連接 MySQL 數據庫，首先定義了 Kafka 的配置，在此基礎上創建一個生產者對象，然后連接 MySQL 數據庫，執行 SQL 查詢語句，遍歷結果集并將每條數據轉換成字符串并發送到 Kafka 隊列中。

以上就是一個基于 Java 的使用 Kafka 讀取 MySQL 數據的簡單示例。在實際業務場景中，還需要考慮到數據同步的方式、持久化的問題以及一些相關的安全性和性能優化問題。