@great-branch-515 Did you end up resolving this? I have the same issue after moving from datahub-prerequisites to my company’s Confluent Kafka (but we’re using security.protocol SASL_SSL and sasl.mechanism PLAIN