Unsubscribe
Any help is appreciated about the exception below.
Also my Kafkasource code is below. The parallelism is 16 for this task.
KafkaSource sourceStationsPeriodic = KafkaSource.<
String>builder()
.setBootstrapServers(parameter.get(
KAFKA_SOURCE_STATIONS_B
Hi everyone,
>From its inception (at least AFAIK), application mode for native Kubernetes
has always created "unmanaged" pods for task managers. I would like to know
if there are any specific benefits to this, or if on the other hand there
are specific reasons not to use Kubernetes Deployments ins
Hello Community,
Please share views for below mail or let me know if any more details needed?
Rgds,
Kamal
From: Kamal Mittal
Sent: 24 July 2023 07:55 AM
To: Kamal Mittal ; user@flink.apache.org
Subject: RE: TCP server socket with Kubernetes Cluster
Hello Community,
Please share views for belo
