Re: Trigger the producer to send data to the consumer after mentioned seconds

you’re using compile target lower then 1.8, what needs to be done depends on your build tool On Fri 7. 1. 2022 at 20:05, Flink Lover wrote: > Hi David, > > Thanks for your explanation! > > I am familiar with how JVM works but why am I facing this issue? What > exactly needs to be done? > > Thank

Re: Trigger the producer to send data to the consumer after mentioned seconds

Hi David, Thanks for your explanation! I am familiar with how JVM works but why am I facing this issue? What exactly needs to be done? Thanks, Martin O. On Sat, Jan 8, 2022 at 12:19 AM David Morávek wrote: > Hi Siddhesh, > > any JVM based language (Java, Scala, Kotlin) compiles into a byte-co

Re: Trigger the producer to send data to the consumer after mentioned seconds

Hi Siddhesh, any JVM based language (Java, Scala, Kotlin) compiles into a byte-code that can be executed by the JVM. As the JVM was evolving over the years, new versions of byte code have been introduced. Target version simply refers the the version of bytecode the compiler should generate. How to

Re: Trigger the producer to send data to the consumer after mentioned seconds

Could you please help me with this? On Fri, Jan 7, 2022 at 11:48 AM Flink Lover wrote: > I tried Flink version 1.14.2 / 1.13.5 > > On Fri, Jan 7, 2022 at 11:46 AM Flink Lover > wrote: > >> Also, I am using flink-connector-kafka_2.11 >> >> val consumer = new FlinkKafkaConsumer[String]("topic_nam

Re: Trigger the producer to send data to the consumer after mentioned seconds

I tried Flink version 1.14.2 / 1.13.5 On Fri, Jan 7, 2022 at 11:46 AM Flink Lover wrote: > Also, I am using flink-connector-kafka_2.11 > > val consumer = new FlinkKafkaConsumer[String]("topic_name", new > SimpleStringSchema(), properties) > > > val myProducer = new FlinkKafkaProducer[String]( >

Re: Trigger the producer to send data to the consumer after mentioned seconds

Also, I am using flink-connector-kafka_2.11 val consumer = new FlinkKafkaConsumer[String]("topic_name", new SimpleStringSchema(), properties) val myProducer = new FlinkKafkaProducer[String]( "topic_name", // target topic new KeyedSerializationSchemaWrapper[String](new SimpleStringSch

Re: Trigger the producer to send data to the consumer after mentioned seconds

Hi All, I checked the Java version using the java -version on the terminal and it gave me 1.8.0.281. Also, the project has been compiled using JDK 8 only which is by default. [image: image.png] What do you mean by target jvm? Also, what I am trying to achieve is correct? about the windows? Than

Trigger the producer to send data to the consumer after mentioned seconds

Hello Folks! I have a DataStream which sends data to the consumer but I got the data once the code completed its execution. I didn't receive the records as the code was writing it to the topic. I was able to achieve this behavior using AT_LEAST_ONCE property but I decided to implement Watermarks.