kafka服務(wù)端口如何連接 kafka 服務(wù)端
Scoopon優(yōu)惠購(gòu)跨境問(wèn)答2025-05-251341
要連接Kafka服務(wù)端口,你需要知道Kafka服務(wù)的IP地址和端口號(hào)。然后,你可以使用Java、Python等編程語(yǔ)言的庫(kù)來(lái)連接到Kafka。以下是一個(gè)簡(jiǎn)單的Java示例:
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.common.serialization.StringDeserializer;
public class KafkaConsumerExample {
public static void main(String[] args) {
String bootstrapServers = "localhost:9092"; // 你的Kafka服務(wù)的IP地址和端口號(hào)
String topic = "your_topic"; // 你的Kafka主題名稱(chēng)
try (KafkaConsumer<String, String> consumer = new KafkaConsumer<>(
ConsumerConfig.Builder.create()
.setBootstrapServers(bootstrapServers)
.setGroupId("test-group") // 如果你需要的話
.setAutoCommit(true)
.setKeyDeserializer(new StringDeserializer())
.setValueDeserializer(new StringDeserializer())
)) {
while (true) {
ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
for (ConsumerRecord<String, String> record : records) {
System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
}
}
}
}
}
請(qǐng)將上述代碼中的your_topic
替換為你要消費(fèi)的主題名稱(chēng),將bootstrapServers
替換為你的Kafka服務(wù)端口。
本文內(nèi)容根據(jù)網(wǎng)絡(luò)資料整理,出于傳遞更多信息之目的,不代表金鑰匙跨境贊同其觀點(diǎn)和立場(chǎng)。
轉(zhuǎn)載請(qǐng)注明,如有侵權(quán),聯(lián)系刪除。
評(píng)論列表

Kafka消費(fèi)者在消費(fèi)數(shù)據(jù)時(shí),如果遇到網(wǎng)絡(luò)問(wèn)題或者服務(wù)器故障,應(yīng)該如何處理?