Hello Matthias and others
I am trying to configure a Kafka Sink with SSL properties as shown further
below.
But in the logs I see warnings:
2022-03-21 12:30:17,108 WARN
org.apache.kafka.clients.admin.AdminClientConfig [] - The
configuration 'group.id' was supplied but isn't a known
Hi,
Your usage looks good to me, but could you provide the exception (if any) or
the unexpected behavior you met after starting the job? It’s difficult to debug
with only these configurations.
Best regards,
Qingsheng
> On Mar 18, 2022, at 01:04, HG wrote:
>
> Hi Matthias,
>
> It should
Hi Matthias,
It should be probably be like this:
Properties SinkkafkaProps = new Properties();
SinkkafkaProps.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,
outputBrokers);
SinkkafkaProps.setProperty("ssl.truststore.type", trustStoreType);
Could you share more details on what's not working? Is the
ssl.trustore.location accessible from the Flink nodes?
Matthias
On Thu, Mar 17, 2022 at 4:00 PM HG wrote:
> Hi all,
> I am probably not the smartest but I cannot find how to set ssl-properties
> for a Kafka Sink.
> My assumption was
Hi all,
I am probably not the smartest but I cannot find how to set ssl-properties
for a Kafka Sink.
My assumption was that it would be just like the Kafka Consumer
KafkaSource source = KafkaSource.builder()
.setProperties(kafkaProps)
.setProperty("ssl.truststore.type",
