我安装了MongoDB接收器连接器和连接转换插件,因为我希望将字段的值从Unix历元转换到以前的日期,以便在Mongo上写入数据,但是Kafka Connect会抛出错误。
Invalid value class org.apache.kafka.connect.transforms.TimestampConverter for configuration transforms.ttl.t
ype: Transformation is abstract and cannot be created. Did you mean org.apache.kafka.connect.transforms
我想收到卡夫卡到Flink程序的最新数据,但是Flink正在阅读历史数据。我已经将auto.offset.reset设置为latest,如下所示,但是它没有工作
properties.setProperty("auto.offset.reset", "latest");
Flink程序正在使用下面的代码从Kafka接收数据
//getting stream from Kafka and giving it assignTimestampsAndWatermarks
DataStream<JoinedStreamEvent> raw_
我正在运行一个数据管道,这样我就可以通过jdbc连接将数据从sql db读取到kafka主题中,我在Elasticsearch中使用kafka接收器连接器来接收这些数据。
我需要重新设置这条管道。为此,我希望重置侦听jdbc连接主题的使用者组。因此,我运行以下命令
kafka-consumer-groups --reset-offsets --to-earliest --all-topics --execute --group mygroup --bootstrap-server myserver:9092
但我知道这个错误
Error: Assignments can only be res