kafka模擬客戶端傳送 接受訊息

2021-09-20 08:36:40 字數 1059 閱讀 8234

producer   訊息的生成者,即發布訊息

consumer   訊息的消費者,即訂閱訊息

broker     kafka以集群的方式執行,可以由乙個或多個服務組成,服務即broker

zookeeper  協調** 

一、建立topic

建立完後可以使用list檢視下

二、重新開啟兩個終端 假設乙個終端傳送訊息 乙個終端接收訊息,這裡:

producer,指定的socket(localhost+9092),說明生產者的訊息要發往kafka,也即是broker

consumer, 指定的socket(localhost+2181),說明消費者的訊息來自zookeeper(協調**)

在終端9092中,啟動為提供者

./kafka-console-producer.sh --broker-list localhost:9092 --topic first_topic
在另乙個終端2181中,啟動為消費者

./kafka-console-consumer.sh --zookeeper localhost:2181 --topic first_topic --from-beginning
隨後你在9092中輸入的資料,就會在2181的控制台列印出來了~ 結束。

UDP TCP客戶端傳送與接受資料

1.建立套接字 2.傳送和接收 3.關閉套接字 import socket udp類似寫信 socket.af inetinternet通訊 socket.af unix本機通訊 socket.sock dgram流式套接字 socket.sock stream資料報套接字 建立套接字 udp so...

C 模擬客戶端傳送資料示例

在給一些客戶端做伺服器端支援時,發現他們提交上來的資料大都不是http請求格式,因而使用request.form獲取不到內容,今天用c 做下模擬,並演示下資料接收。1.傳送文字 1 客戶端傳送文字 複製內容到剪貼簿程式 using system using system.io using syste...

windows tcp 客戶端 傳送檔案

include include include pragma comment lib,wsock32.lib char host name 192.168.58.128 local host int port 8000 int main int argc,char argv else char bu...