@flink.apache.org
Тема: Re: SSL Kafka PyFlink
Hi Phil,
The kafka configuration keys of ssl maybe not correct. You can refer the kafka
document[1] to get the ssl configurations of client.
[1] https://kafka.apache.org/documentation/#security_configclients
Best,
Zhongqiang Gong
Phil Stavridis mailto:phi
Hi Phil,
The kafka configuration keys of ssl maybe not correct. You can refer the
kafka document[1] to get the ssl configurations of client.
[1] https://kafka.apache.org/documentation/#security_configclients
Best,
Zhongqiang Gong
Phil Stavridis 于2024年5月17日周五 01:44写道：
> Hi,
>
> I have a PyFl
Hi,
I have a PyFlink job that needs to read from a Kafka topic and the
communication with the Kafka broker requires SSL.
I have connected to the Kafka cluster with something like this using just
Python.
from confluent_kafka import Consumer, KafkaException, KafkaError
def get_config(bootstrap
