Hi Team,
We recently have started a use case where there would be involvement of
Kafka and Flink's low level APIs like map and process functions and since I
am entirely new to these stuffs, I couldn't get the exact approach/way to
test Kafka connector and low level APIs.
So can anyone share any w
Hello folks,
Any help is appreciated.
J.
On Sat, Sep 30, 2023 at 1:47 PM joshua perez wrote:
> Hi Team,
>
> We recently have started a use case where there would be involvement of
> Kafka and Flink's low level APIs like map and process functions and since I
> am entirely
Hi team,
I am trying to read the records from the Kafka topic and below is my very
basic code as of now
from pyflink.datastream.connectors.kafka import FlinkKafkaConsumer
from pyflink.datastream.stream_execution_environment import
StreamExecutionEnvironment, RuntimeExecutionMode
from pyflink.comm
Hi Team,
you can ignore this thread. I was able to resolve this.
J.
On Mon, Oct 2, 2023 at 8:40 PM joshua perez wrote:
> Hi team,
>
> I am trying to read the records from the Kafka topic and below is my very
> basic code as of now
>
> from pyflink.datastream.conne
