Так, с питоном не зашло, тогда похожее про scala) вот такой

конфиг:

props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka:9093")
props.put("schema.registry.url", "http://schema.reg.url")
props.put(ConsumerConfig.GROUP_ID_CONFIG, groupId)
props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "true")
props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest")
props.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "10000")
props.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, "30000")
props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, classOf[StringDeserializer].getCanonicalName)
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,classOf[StringDeserializer].getCanonicalName)
//Use Specific Record or else you get Avro GenericRecord.
props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SSL")
props.put(SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG,
"/Path/to/kafka.client.keystore.jks")
props.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG,
"/Path/to//kafka.server.truststore.jks")
props.put(SslConfigs.SSL_KEY_PASSWORD_CONFIG, "password")
props.put(SslConfigs.SSL_KEYSTORE_PASSWORD_CONFIG, "password")
props.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, "password")
Пароль проверил через keytool - он правильный.
Но при попытке создать consumer private val consumer = new KafkaConsumer[String, String](props)

Валится с ошибкой
Caused by: org.apache.kafka.common.KafkaException: Failed to load SSL keystore /Users/oilinsky/kafka_connect/python_kafka_connect/kafka.server.truststore.jks of type JKS
Caused by: java.io.IOException: Keystore was tampered with, or password was incorrect
Caused by: java.security.UnrecoverableKeyException: Password verification failed

Это как так?)

а пароль точно на оба нужен?