Kafka Consumer lấy cặp giá trị khóa

Question

Tôi hiện đang làm việc với Kafka và Flink, tôi có kafka đang chạy trên máy tính cục bộ của mình và tạo ra một chủ đề đang được tiêu thụ.

Desktop \ Kafka \ bin \ windows> Kafka-console-consumer.bat --zookeeper localhost: 2181 kiểm tra -topic

nhưng nó chỉ được lấy thông điệp,

là có một cách để nhận thêm chi tiết về tin nhắn? cho phép nói thời gian? Chìa khóa? Tôi đã kiểm tra tài liệu kafka nhưng tôi không tìm thấy nội dung nào về chủ đề này

Answer 1

Sử dụng ngoài bảng điều khiển dành cho người tiêu dùng (Tôi đang sử dụng Kafka 0.9.0.1), bạn chỉ có thể in khóa và giá trị của thư bằng các định dạng khác nhau. Để in khóa, hãy đặt thuộc tính print.key thành true.

Có một thuộc tính key.separator khác theo mặc định là "\ t" (tab) mà bạn cũng có thể thay đổi thành bất kỳ thứ gì bạn muốn.

Để đặt các thuộc tính này, bạn có thể tạo tệp cấu hình và sử dụng --consumer.config hoặc chuyển các thuộc tính bằng cách sử dụng --property key = value.

Bạn cũng có thể triển khai trình định dạng của riêng mình và sử dụng nó với tùy chọn - định dạng nhưng bạn vẫn sẽ chỉ có khóa và giá trị vì đó là những đặc điểm MessageFormatter cung cấp (xem writeTo bên dưới).

trait MessageFormatter { 
    def writeTo(key: Array[Byte], value: Array[Byte], output: PrintStream) 

    def init(props: Properties) {} 

    def close() {} 
} 

Ví dụ:

./bin/kafka-console-consumer.sh --new-consumer --bootstrap-server kafka-1:9092 --topic topic1 --property print.key=true --property key.separator="-" --from-beginning 
key-p1 
key-p2 
key-p3 
null-4 
null-8 
null-0