: FlinkKafkaProducer Fails with "Topic not present in metadata"
So I actually discovered what the problem is after some extensive debugging
with confluent.
My Kafka Producer was attempting to send a record to specific topic partition.
The topic partition did not exist. So what the err
;user@flink.apache.org"
Subject: Re: FlinkKafkaProducer Fails with "Topic not present in metadata"
Hi Joseph,
Thanks for the thorough information. Do you happen to have the trace level logging available? If so, do you mind puttng it somewhere so we can take a look
Hi Joseph,
Thanks for the thorough information. Do you happen to have the trace level
logging available? If so, do you mind puttng it somewhere so we can take a
look?
Thanks,
Jiangjie (Becket) Qin
On Thu, Dec 3, 2020 at 8:55 PM Joseph Lorenzini
wrote:
> Hi all,
>
> I have a flink job that use
Hi all,
I have a flink job that uses FlinkKafkaConsumer to consume messages off a kafka
topic and a FlinkKafkaProducer to produce records on a Kafka topic. The
consumer works fine. However, the flink job eventually fails with the following
exception.
Caused by: org.apache.kafka.common.errors.T
