'OPENSSL_Uplink(54256568,08): no OPENSSL_Applink in Kafka Consumer -python
I'm trying to consume Kafka message using Confluent Kafka with SSL in python using below code:
try:
consumer_config = {
'bootstrap.servers': 'bootstrap server details',
'security.protocol': 'SSL',
'ssl.keystore.location': 'path to .p12 file',
'ssl.keystore.password': 'password',
'ssl.ca.location': 'Path to pem file',
'group.id': 'group id' ,
'auto.offset.reset': 'earliest'
}
consumer = Consumer(consumer_config)
consumer.subscribe(topic)
try:
while True:
print("Listening")
# read single message at a time
msg = consumer.poll(0)
if msg is None:
time.sleep(5)
continue
if msg.error():
print("Error reading message : {}".format(msg.error()))
continue
print(msg)
consumer.commit()
except Exception as ex:
print("Kafka Exception : {}", ex)
finally:
print("closing consumer")
consumer.close()
except Exception as e:
print(e)
logger.error("Error while consuming Kafka message!!")
I'm getting an error saying :
OPENSSL_Uplink(54256568,08): no OPENSSL_Applink
Is the code which I have written above incorrect. Can anyone correct me what am I doing wrong.
Many thanks.
PS: I have searched with this error online but couldn't find any relevant solution.
Sources
This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.
Source: Stack Overflow
| Solution | Source |
|---|
