Hi, everyone
I'm using Flink 1.14 to consume Kafka data, which version is 0.11. And
there are some errors while running.
Caused by: java.lang.NoSuchMethodError:
org.apache.kafka.clients.consumer.KafkaConsumer.poll(Ljava/time/Duration;)Lorg/apache/kafka/clients/consumer/ConsumerRecords;
at
org.apa
big +1 for this feature，
1. Reset kafka offset in certain cases.
2. Stop checkpoint in certain cases.
3. Change log level for debug.
刘建刚 于2021年6月11日周五 下午12:17写道：
> Thanks for all the discussions and suggestions. Since the topic has
> been discussed for about a week, it is time to
provide a concrete
> example
>
> On Fri, May 22, 2020 at 3:46 PM Jary Zhen wrote:
>
>> Hello everyone,
>>
>>First，a brief pipeline introduction:
>> env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
>> consume multi kafka topic
>
Hello everyone,
First，a brief pipeline introduction:
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
consume multi kafka topic
-> union them
-> assignTimestampsAndWatermarks
-> keyby
-> window() and so on …
It's a very normal way use flink to p
