我对Kafka还是个新手，正在寻找解决以下问题的方法：使用kafka connect smt，可以操纵主题的一部分或其名称。有没有一种方法可以从数据流中获取日期并从中构建索引名？例如：
{"transmitdate": "2020-03-20T14: 00: 00"} -> index name: foo-2020-03-20
谢谢。
5tmbdcev1#
所以我自己找到了答案。连接器包中的messagetimestamprouter非常适合此任务。这里有一个链接：https://docs.confluent.io/current/connect/transforms/messagetimestamprouter.html#messagetimestamprouter
1条答案
按热度按时间5tmbdcev1#
所以我自己找到了答案。连接器包中的messagetimestamprouter非常适合此任务。
这里有一个链接：
https://docs.confluent.io/current/connect/transforms/messagetimestamprouter.html#messagetimestamprouter