共計 1528 個字符，預計需要花費 4 分鐘才能閱讀完成。

在 Java 中，你可以使用 Apache Kafka 的 Java 客戶端庫來從 Kafka 中讀取數據。下面是一個簡單的示例代碼：

首先，你需要在你的項目中添加 Kafka 的 Java 客戶端庫的依賴。你可以在你的構建工具（如 Maven 或 Gradle）的配置文件中添加以下依賴：

<!-- Kafka client -->
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>2.8.0</version>
</dependency>

然后，你可以使用以下代碼從 Kafka 中讀取數據：

import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.common.serialization.StringDeserializer;

import java.util.Collections;
import java.util.Properties;

public class KafkaConsumerExample {public static void main(String[] args) {// Kafka 集群的地址
        String bootstrapServers = "localhost:9092";
        // 消費者組的 ID
        String groupId = "my-group";
        // 要消費的主題
        String topic = "my-topic";

        // 配置消費者的屬性
        Properties properties = new Properties();
        properties.put("bootstrap.servers", bootstrapServers);
        properties.put("group.id", groupId);
        properties.put("key.deserializer", StringDeserializer.class);
        properties.put("value.deserializer", StringDeserializer.class);

        // 創建消費者
        KafkaConsumer<String, String> consumer = new KafkaConsumer<>(properties);

        // 訂閱主題
        consumer.subscribe(Collections.singletonList(topic));

        // 無限循環從 Kafka 中讀取消息
        while (true) {ConsumerRecords<String, String> records = consumer.poll(1000);
            for (ConsumerRecord<String, String> record : records) {System.out.println("Received message: " + record.value());
            }
        }
    }
}

以上代碼創建了一個消費者并訂閱了一個主題。然后，通過調用 consumer.poll(1000) 來從 Kafka 中拉取數據。在這個例子中，我們只是簡單地將接收到的消息打印到控制臺上。

請確保替換 bootstrapServers、groupId 和topic為你要連接的 Kafka 集群的地址、你的消費者組的 ID 和你要消費的主題。

希望對你有幫助！

丸趣 TV 網 – 提供最優質的資源集合！