普罗米修斯·卡夫卡适配器
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__是一个特殊的标签，用于定义度
2022-08-24 09:58:46
32KB
1
csv-kafka-json
一个简单的程序，将CSV文件作为JSON编码的消息发送到Kafka。 每行都作为单独的消息发送。
用法
在运行应用程序之前，请确保更改以主类编写的配置。
2021-12-30 20:59:12
8KB
1
基于SpringBoot+Kakfa小demo，生产者推送消息到kafka队列，消费者从消息队列获取消息并消费
2021-07-19 13:02:58
28.95MB
1
带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
2021-05-02 22:02:57
10KB
1