亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

Kafka生產者元數據怎么獲取

小億
110
2023-11-22 22:20:50
欄目: 大數據

要獲取Kafka生產者的元數據,可以使用Kafka提供的AdminClient API。以下是一個示例代碼:

import java.util.Properties;
import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.ConsumerGroupListing;
import org.apache.kafka.clients.admin.ListConsumerGroupsResult;
import org.apache.kafka.clients.admin.ListTopicsResult;
import org.apache.kafka.clients.admin.TopicListing;

public class KafkaProducerMetadata {
    public static void main(String[] args) {
        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092"); // Kafka集群的地址

        try (AdminClient adminClient = AdminClient.create(props)) {
            // 獲取所有主題的元數據
            ListTopicsResult topicsResult = adminClient.listTopics();
            topicsResult.listings().get().forEach(topicListing -> {
                System.out.println("Topic: " + topicListing.name());
            });

            // 獲取所有消費者組的元數據
            ListConsumerGroupsResult consumerGroupsResult = adminClient.listConsumerGroups();
            consumerGroupsResult.all().get().forEach(consumerGroupListing -> {
                System.out.println("Consumer Group: " + consumerGroupListing.groupId());
            });
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

上述代碼使用AdminClient API創建一個AdminClient實例,并使用該實例來獲取所有主題和消費者組的元數據。可以根據需要進行修改和擴展。

0
桦川县| 淮滨县| 盐山县| 旺苍县| 柘荣县| 岢岚县| 积石山| 当雄县| 沁阳市| 波密县| 两当县| 定边县| 微山县| 榆树市| 安塞县| 兰溪市| 城固县| 永吉县| 沅陵县| 克拉玛依市| 屯昌县| 政和县| 澄城县| 上饶县| 西华县| 思茅市| 措美县| 奎屯市| 灯塔市| 仙居县| 那坡县| 郴州市| 诏安县| 应用必备| 页游| 白沙| 泾川县| 汉中市| 北海市| 鹤岗市| 彰化县|