[root@yws85 ~]# cd /opt/software/kafka/
[root@yws85 kafka]# bin/kafka-topics.sh \
> --create \
> --zookeeper 192.168.0.85:2181,192.168.0.86:2181,192.168.0.87:2181/kafka \
> --replication-factor 3 \
> --partitions 3 \
> --topic g5
created topic "g5".
[root@yws85 kafka]# ll bin
kafka-console-producer.sh
kafka-console-consumer.sh
不知道如何使用得話
[root@yws85 kafka]# cd bin
[root@yws85 bin]#./kafka-console-producer.sh
就可以看到使用
[root@yws85 kafka]#bin/kafka-console-producer.sh \
--broker-list 192.168.0.85:9092,192.168.0.86:9092,192.168.0.87:9092 \
--topic g5
[root@yws85 kafka]#bin/kafka-console-consumer.sh \
--zookeeper 192.168.0.85:2181,192.168.0.86:2181,192.168.0.87:2181/kafka \
--topic g5 \
--from-beginning
注意2者的區別
這時在生產者輸入訊息,消費者就會得到,
在未來當中,你不知道你部署的kafka是否ok,自己就需要模擬一下、
乙個是發資料kafka-console-producer.sh,乙個是消費資料kafka-console-consumer.sh。
模擬實現Spring IOC
通過在類上標註 registration 註冊進容器,injection從容器注入物件 容器類 public class springcontainer else bean.setbeanclass c mappropsmap new hashmap 處理注入屬性 field props c.get...
模擬實現strcmp
函式簡介 原型 int strcmp const char s1,const char s2 所在標頭檔案 string.h 功能 比較字串s1和s2。一般形式 strcmp 字串1,字串2 說明 當s1注意不是 1 當s1 s2時,返回值 0 當s1 s2時,返回正數 注意不是1 如下 int m...
模擬實現strncat
模擬實現strncat 在系統庫函式中,存在strncat這個函式,它用於字串的追加,就是在乙個字串後面再追加乙個字串,它的函式原型為 char strncat char strdest,const char strsource,size t count 在其中,strdest為目標字串,strso...