[QUESTION] SSL: UNEXPECTED_MESSAGE

[rvaidun]

Hi All,
My consumers that are running for a long time are not receiving messages that are sent to Kafka. I am seeing lots of log such as this in my consumer services:

Unable connect to node with id 0: [SSL: UNEXPECTED_MESSAGE] unexpected message (_ssl.c:1149)
Unable connect to node with id 1: [SSL: UNEXPECTED_MESSAGE] unexpected message (_ssl.c:1149)
Unable connect to node with id 2: [SSL: UNEXPECTED_MESSAGE] unexpected message (_ssl.c:1149)

aiokafka/aiokafka/client.py

Lines 475 to 481 in 256ce17

	except (OSError, asyncio.TimeoutError, KafkaError) as err:
	log.error("Unable connect to node with id %s: %s", node_id, err)
	if group == ConnectionGroup.DEFAULT:
	# Connection failures imply that our metadata is stale, so
	# let's refresh
	self.force_metadata_update()
	return None

Would this be causing issues with receiving messages?

[amabilee]

Ensure that the certificates and keys are correctly configured for both Kafka brokers and consumers.
Make sure you are using the latest version of the aiokafka.
Any potential network issues or firewalls that might be interfering with the SSL communication.