普罗米修斯·卡夫卡适配器 Prometheus-kafka-adapter是一项服务，该服务通过接收指标，将其编组为JSON并将其发送到。 输出 可以根据SERIALIZATION_FORMAT配置变量在kafka主题中编写JSON或Avro-JSON消息。 JSON格式 { " timestamp " : " 1970-01-01T00:00:00Z " , " value " : " 9876543210 " , " name " : " up " , " labels " : { " __name__ " : " up " , " label1 " : " value1 " , " label2 " : " value2 " } } timestamp和value是保留值，不能用作标签名称。 __name__是一个特殊的标签，用于定义度

csv-kafka-json 一个简单的程序，将CSV文件作为JSON编码的消息发送到Kafka。 每行都作为单独的消息发送。 用法 在运行应用程序之前，请确保更改以主类编写的配置。

基于SpringBoot+Kakfa小demo，生产者推送消息到kafka队列，消费者从消息队列获取消息并消费

带Kafka的样本Spring Boot 公开了一个使用json消息并发布到kafka主题中的api 要通过泊坞窗启动zookeeper和kafka，请执行以下操作： docker-compose up 生成应用程序映像 docker build --no-cache -t sample_kafka:0.0.1 . -f docker\Dockerfile 创建主题： bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic test 要开始制作，请执行以下操作： bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 要启动消费者： bin