訊息佇列 Kafka和rabbitMQ

0.建立topic

./bin/kafka

-topics.sh

--create--

zookeeper

localhost:2181--

replication

-factor1-

-partitions1-

-topic

test

1.檢視kafka topic列表：

/bin/kafka-topic.sh --zoopkeeper 

127.0.0.1:2181

--list

2.檢視kafka特定topic的詳情，使用--topic與--describe引數：

/bin/kafka-topic.sh --zookeeper 127.0.01:2181 --topic

lx_test_topic

--describe

3.檢視consumer group列表，使用--list引數

bin/kafka-consumer-groups.sh --zookeeper 127.0.0.1:2181 --list

bin/kafka-consumer-groups.sh --zookeeper 127.0.0.1:2181 --group console-consumer-11967 --describe

5.控制台向topic生產資料bin/kafka-console-producer.sh --broker-list node86:9092 --topic t_cdr

bin/kafka-console-consumer.sh  --zookeeper node01:2181  --topic t_cdr --from-beginning

./bin/kafka

-topics.sh

--zookeeper

127.0.

0.1:2181--

delete--

topic

test

8.檢視rabbitmq服務狀態

rabbitmqctl status

訊息佇列 訊息佇列 kafka

kafka是乙個分布式的基於發布 訂閱模式的訊息佇列，主要用於大資料實時處理領域。要理解kafka首先要有分布式的概念，要有訊息佇列的概念。分布式系統最大的優勢就是解耦和削峰，這種情況下，a系統生成了乙個訊息，b系統非同步獲取，那麼就需要乙個存放訊息的訊息佇列 mq 相比較傳統的訊息佇列，訊息被消費...

訊息佇列 RabbitMQ和Kafka

2種模式 點對點 consumer主動對queue監控，檢查是否收到訊息 優點 解耦 通過中介軟體通訊 冗餘 可做快取 擴充套件性順序保證 非同步通訊 consumer即使down掉，訊息還是儲存在queue，等consumer恢復會自動處理訊息 關於broker裡的exchange不可以直接將訊息...

訊息佇列 Kafka學習

kafka是乙個分布式的訊息佇列，學習見apache kafka文件，中文翻譯見kafka分享，乙個簡單的入門例子見kafka 入門例項。本文只針對自己感興趣的點記錄下。producer consumer 訊息的生成者和使用者。broker kafka server充當broker角色，起到訊息佇列...