文件名称：epochConvertor:从KAFKA主题读取纪元并将RFC3339写入另一个主题
文件大小：33KB
文件格式：ZIP
更新时间：2024-03-26 15:13:58
Go
时间转换器 该项目开始以时代格式从kafka主题中消耗时间，并将其转换为RFC3339格式，然后将其生成为另一个kafka主题。 默认主题为： 消费者从输入主题开始消费 生产者开始生产到输出主题 该项目包含三个部分： 消费者：从kafka主题消费时代 生产者：将RFC3339格式的时间转换为kafka并产生时间 指标：从生产者和消费者收集指标。 配置导出器 姓名 描述 类型 默认 METRICS_PATH 指标路径 细绳 /指标 LISTEN_PORT 出口商监听端口 数字 8081 配置使用者 姓名 描述 类型 默认 CONSUMER_VERSION 卡夫卡版 细绳 2.7.0 CONSUMER_GROUP 消费者组名称 细绳 时代消费者 CONSUMER_TOPIC 卡夫卡消费主题 细绳 输入 CONSUMER_BROKERS 卡夫卡经纪人 逗号分隔的主机：端口 1
【文件预览】：
epochConvertor-master
----helper_test.go(221B)
----consumer()
--------helper_test.go(2KB)
--------consumer.go(896B)
--------consumer_test.go(562B)
--------helper.go(7KB)
----go.mod(656B)
----go.sum(46KB)
----metrics()
--------metrics_test.go(1KB)
--------config_test.go(365B)
--------metrics.go(1KB)
--------config.go(421B)
----Dockerfile(510B)
----epochConvertor.go(726B)
----producer()
--------helper_test.go(1KB)
--------producer_test.go(582B)
--------producer.go(2KB)
--------helper.go(5KB)
----README.md(5KB)
----helper.go(509B)
----.gitignore(662B)