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

溫馨提示×

kafka怎么向topic里發送數據

小億
303
2024-01-25 00:07:01
欄目: 編程語言

Kafka提供了多種方式向topic發送數據,以下是其中兩種常見的方法:

  1. 使用命令行工具kafka-console-producer.sh(或kafka-console-producer.bat):
kafka-console-producer.sh --broker-list localhost:9092 --topic <topic-name>

該命令會啟動一個交互式的控制臺,你可以在控制臺中輸入要發送的消息,按Enter鍵發送。

  1. 使用Kafka客戶端API發送數據:
import org.apache.kafka.clients.producer.*;

import java.util.Properties;

public class KafkaProducerExample {

    public static void main(String[] args) {

        String topicName = "<topic-name>";
        String key = "key1";
        String value = "value1";

        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092");
        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);

        ProducerRecord<String, String> record = new ProducerRecord<>(topicName, key, value);
        producer.send(record);

        producer.close();
    }
}

請確保Kafka的地址和端口與你的實際環境相匹配,并替換、key和value為你要發送的數據。

這是Kafka的簡單示例代碼,你可以根據你的需求自定義更多的配置和發送邏輯。

0
普兰店市| 洪泽县| 安福县| 天柱县| 金阳县| 龙泉市| 建阳市| 白城市| 增城市| 朝阳市| 九龙坡区| 安溪县| 东丽区| 汕尾市| 观塘区| 诏安县| 宜都市| 格尔木市| 会昌县| 娱乐| 六安市| 旌德县| 郁南县| 礼泉县| 昌平区| 成安县| 库车县| 崇信县| 茶陵县| 章丘市| 惠州市| 淮北市| 东丽区| 泾源县| 汝城县| 乌拉特后旗| 忻城县| 淮滨县| 庆阳市| 苏尼特右旗| 福贡县|