apache-kafka - Kafka Consumer 获取键值对

Question

我目前正在使用 Kafka 和 Flink，我在本地 PC 上运行了 kafka，并且我创建了一个正在使用的主题。

桌面\kafka\bin\windows>kafka-console-consumer.bat --zookeeper localhost:2181 -topic test

但它只是检索消息，

有没有办法获得有关消息的更多详细信息？让我们说时间？ key ？我检查了 kafka 文档，但没有找到有关此主题的内容

Answer 1

使用开箱即用的控制台消费者(我使用的是 Kafka 0.9.0.1)，您只能使用不同格式打印消息的键和值。要打印 key ，请设置属性 print.key=true .

还有一个属性key.separator默认情况下是“\t”(一个选项卡)，您也可以更改为任何您想要的。

要设置这些属性，您可以创建一个配置文件并使用 --consumer.config <config file>或使用 --property key=value 传递属性.

您还可以实现自己的格式化程序并将其与 --formatter 一起使用选项，但您仍然只有键和值，因为这是 MessageFormatter 特征提供的(参见下面的 writeTo)。

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

    def init(props: Properties) {}

    def close() {}
}

例如:

./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