java获取kafkaconsumer的host
时间: 2023-12-12 08:03:05 浏览: 83
获取kafka 相关消息 JAVA
要获取KafkaConsumer连接的Kafka集群的主机名或IP地址,您可以使用KafkaConsumer的bootstrapServers()方法。以下是一个示例代码,演示如何获取KafkaConsumer连接的Kafka集群的主机名或IP地址:
```java
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import java.util.Properties;
public class ConsumerHostExample {
public static void main(String[] args) {
Properties props = new Properties();
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
props.put(ConsumerConfig.GROUP_ID_CONFIG, "test-group");
props.put(ConsumerConfig.CLIENT_ID_CONFIG, "test-client");
props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
String bootstrapServers = consumer.bootstrapServers();
System.out.println("KafkaConsumer bootstrap servers: " + bootstrapServers);
consumer.close();
}
}
```
在上面的示例代码中,我们创建了一个KafkaConsumer实例,并设置了bootstrap.servers属性为"localhost:9092"。使用consumer.bootstrapServers()方法即可获取该KafkaConsumer连接的Kafka集群的主机名或IP地址。输出结果应该类似于:"KafkaConsumer bootstrap servers: localhost:9092"。
阅读全文