Kafka - Start consumer

要啟用 Consumer 去接收 Topic 的訊息,可調用 kafka-console-consumer.sh,帶入參數 –bootstrap-server 指定 Bootstrap server 位置、–topic 參數指定 Topic。 ...

September 21, 2018 · 1 min · 84 words · Larry Nung

Kafka - Send messages

要使用 Kafka 發送訊息到指定的 Topic,可以調用 kafka-console-producer.sh,帶入參數 –broker-list 指定 broker 的位置、–topic 參數指定 topic。 ...

September 21, 2018 · 1 min · 90 words · Larry Nung

Kafka - List topic

要列出 Kafka 的 Topic,可以調用 kafka-topics.sh,帶入參數 –list 指示要列出 topic、–zookeeper 參數指定 ZooKeeper 位置。 ...

September 20, 2018 · 1 min · 76 words · Larry Nung

Kafka - Create topic

要建立 Kafka 的 Topic,可以調用 kafka-topics.sh,帶入 –create 參數指定創建 topic、–zookeeper 參數指定 zookeeper 位置、–topic 參數指定要創建的 topic。 ...

September 20, 2018 · 1 min · 109 words · Larry Nung

Kafka - Download and start kafka server

要使用 Kafka 首先須確定環境中有安裝 Java。 ...

September 19, 2018 · 1 min · 98 words · Larry Nung