时间转换器
该项目开始以时代格式从kafka主题中消耗时间,并将其转换为RFC3339格式,然后将其生成为另一个kafka主题。
默认主题为:
消费者从输入主题开始消费
生产者开始生产到输出主题
该项目包含三个部分:
消费者:从kafka主题消费时代
生产者:将RFC3339格式的时间转换为kafka并产生时间
指标:从生产者和消费者收集指标。
配置导出器
姓名
描述
类型
默认
METRICS_PATH
指标路径
细绳
/指标
LISTEN_PORT
出口商监听端口
数字
8081
配置使用者
姓名
描述
类型
默认
CONSUMER_VERSION
卡夫卡版
细绳
2.7.0
CONSUMER_GROUP
消费者组名称
细绳
时代消费者
CONSUMER_TOPIC
卡夫卡消费主题
细绳
输入
CONSUMER_BROKERS
卡夫卡经纪人
逗号分隔的主机:端口
1
2021-03-07 09:04:33
33KB
Go
1