Bạn có chắc chắn muốn xóa bài viết này không ?
Bạn có chắc chắn muốn xóa bình luận này không ?
Tìm hiểu về apache kafka (tiếp)
Cài đặt
Download kafka từ một trong các link dưới đây:
https://www.apache.org/dyn/closer.cgi?path=/kafka/0.8.2.0/kafka_2.10-0.8.2.0.tgz
Kafka là một ứng dụng scala (chạy trên JVM) nên chỉ cần máy bạn cài sẵn java là hoàn toàn có thể chạy một cách dễ dàng.
Sau khi download ở đường link trên, bạn giải nén vào đâu đó:
tar -xzf kafka_2.10-0.8.2.0.tgz
cd kafka_2.10-0.8.2.0
Bộ cài kafka đi kèm với ZooKeeper server rồi nên nếu bạn chưa có zookeeper ở local thì bạn có thể start một server Zookeeper đi kèm bộ cài, chạy dưới dạng một single node:
bin/zookeeper-server-start.sh config/zookeeper.properties
Sau đó bạn có thể khởi động kafka server:
bin/kafka-server-start.sh config/server.properties
Sử dụng manage tool của kafka
Bạn có thể tạo mới một topic với tên là test
bằng dòng lệnh như sau:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
Sau đó kiểm tra topic vừa tạo
bin/kafka-topics.sh --list --zookeeper localhost:2181
Bạn có thể thử gửi vài message vào topic vừa tạo
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
//Đánh message bất kì ở đây
Sau đó bạn có thể sử dụng consumer đi kèm bộ cài để thử in message ở trên ra stdout
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
//Message ở trên sẽ hiện ra
Trong bài viết tiếp theo mình sẽ viết tiếp về cách sử dụng kafka client.







