apache-kafka

29Nhiệt

7Trả lời

Làm cách nào để lấy dữ liệu từ điểm bù cũ ở Kafka?

Tôi đang sử dụng vườn thú để lấy dữ liệu từ kafka. Và ở đây tôi luôn lấy dữ liệu từ điểm bù cuối cùng. Có cách nào để xác định thời gian bù đắp để lấy dữ liệu cũ không? Có một tùy chọn autooffset.rese

9Nhiệt

7Trả lời

kafka NoClassDefFoundError kafka/Kafka

Về Apache-Kafka messaging queue. Tôi đã tải xuống Apache Kafka từ trang tải xuống Kafka. Tôi đã giải nén nó vào /opt/apache/installed/kafka-0.7.0-incubating-src. Các quickstart page nói rằng bạn cần p

5Nhiệt

7Trả lời

Tôi có thể tìm kho lưu trữ maven cho kafka ở đâu?

Tôi muốn thử kafka 0.8 (vì tôi hiểu nó đã được phát hành). Nhưng tôi có thể tìm kho chứa kafka maven ở đâu. Và tôi nên thêm url kho lưu trữ nào? Tôi đã tìm thấy một số blog với <dependency> <grou

17Nhiệt

4Trả lời

Kafka đã sẵn sàng để sử dụng sản xuất chưa?

Tôi có một ứng dụng trong quá trình sản xuất phải xử lý vài gigabyte tin nhắn mỗi ngày. Tôi thích kiến trúc và hiệu suất của Kafka rất nhiều; nó hoàn toàn phù hợp với nhu cầu của tôi. Tôi muốn thay

12Nhiệt

2Trả lời

Kafka 0.8, có thể tạo chủ đề với phân vùng và sao chép bằng cách sử dụng mã java không?

Trong Kafka 0.8beta một chủ đề có thể được tạo ra bằng cách sử dụng lệnh như dưới đây như đã đề cập here bin/kafka-create-topic.sh --zookeeper localhost:2181 --replica 2 --partition 3 --topic test l

5Nhiệt

2Trả lời

Tích hợp Kafka Storm bằng Kafka Spout

Tôi đang sử dụng KafkaSpout. Vui lòng tìm chương trình thử nghiệm dưới đây. Tôi đang sử dụng Storm 0.8.1. Lớp Multischeme có trong Storm 0.8.2. Tôi sẽ sử dụng nó. Tôi chỉ muốn biết các phiên bản trước

6Nhiệt

2Trả lời

Nối tiếp Kafka của một đối tượng

Tôi bắt đầu chơi với Kafka. Tôi đã thiết lập một cấu hình sở thú và tôi đã quản lý để gửi và tiêu thụ các tin nhắn String. Bây giờ tôi đang cố gắng để vượt qua một đối tượng (trong java), nhưng từ một

10Nhiệt

3Trả lời

Khởi động Máy chủ Kafka Vĩnh viễn

Tôi đã thiết lập Kafka trên cá thể Amazon EC2. Tôi đã làm như sau trong dưới đây theo thứ tự: (1) SSH vào Instance (2) Bắt đầu Zookeper (3) Bắt đầu Kafka (4) Thực hiện sản xuất và tiêu dùng Chương Trì