Tìm hiểu về apache kafka (tiếp)
kafka
5
White

Hoàng Minh Trung viết ngày 06/07/2015

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.

Bình luận


White
{{ comment.user.name }}
Bỏ hay Hay
{{comment.like_count}}
Male avatar
{{ comment_error }}
Hủy
   

Hiển thị thử

Chỉnh sửa

White

Hoàng Minh Trung

21 bài viết.
54 người follow
Kipalog
{{userFollowed ? 'Following' : 'Follow'}}
Cùng một tác giả
White
18 15
(Ảnh) Mục đích của bài viết là hướng dẫn cơ bản nhất cho những ai chưa biết về docker, môi trường thực hiện là mac OS. Chuẩn bị Cài đặt virtua...
Hoàng Minh Trung viết hơn 2 năm trước
18 15
White
17 1
Bài viết dịch từ http://arslan.io/tenusefultechniquesingo Sử dụng một GOPATH duy nhất Sử dụng đồng thời nhiều GOPATH sẽ không giúp cho hệ thống ...
Hoàng Minh Trung viết hơn 1 năm trước
17 1
White
13 0
Bài viết dịch từ https://github.com/luciotato/golangnotes/blob/master/OOP.md Mục đích bài viết Học golang dễ dàng hơn với những kiến thức bạn đ...
Hoàng Minh Trung viết hơn 1 năm trước
13 0
Bài viết liên quan
White
2 0
Bạn có một file log, bạn muốn đổ log vào một topic nào đó trên kafka cho một ai đó dùng. Một cách nhanh chóng có thể sử dụng producer console như s...
Quăng viết hơn 1 năm trước
2 0
White
9 2
Giới thiệu (Ảnh) Về cơ bản kafka là hệ thống message pub/sub phân tán mà có khả năng scale rất tốt. Message của kafka được lưu trên đĩa cứng, đồ...
Hoàng Minh Trung viết hơn 2 năm trước
9 2
White
3 0
Khi sử dụng một số hệ thống tính toán phân tán mà setup sẽ mất thời gian như kafka chẳng hạn, đôi khi bạn muốn kafka chỉ chạy trong test session rồ...
Hoàng Minh Trung viết hơn 2 năm trước
3 0
{{like_count}}

kipalog

{{ comment_count }}

bình luận

{{liked ? "Đã kipalog" : "Kipalog"}}


White
{{userFollowed ? 'Following' : 'Follow'}}
21 bài viết.
54 người follow

 Đầu mục bài viết

Vẫn còn nữa! x

Kipalog vẫn còn rất nhiều bài viết hay và chủ đề thú vị chờ bạn khám phá!