91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

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
内乡县| 台安县| 集安市| 麻栗坡县| 两当县| 邮箱| 措勤县| 迁安市| 瓮安县| 桓台县| 佳木斯市| 女性| 常山县| 府谷县| 邢台市| 会泽县| 城固县| 玛多县| 乌兰察布市| 石景山区| 浦江县| 东方市| 闽清县| 自贡市| 富民县| 宁明县| 宜都市| 克东县| 张家港市| 北安市| 阜新| 禹州市| 德清县| 鲁甸县| 金溪县| 忻州市| 舞阳县| 永年县| 阳信县| 易门县| 梅河口市|