Kafka перестает работать после развертывания на Heroku
У меня микросервисная архитектура включает как минимум 3 сервиса, которые используют Kafka (через Cloud Karafka): некоторый обмен данными и уведомления по электронной почте клиентам в конечной точке. Локально работает отлично, без ошибок. Но после развертывания на Heroku перестает работать. Проверил логи для каждого сервиса через herokuCli: ошибок нет и вылетов...
Я имею в виду все остальные сервисы, запросы работают хорошо, кроме обмена данными и рассылки через Облако. Я видел несколько статей и вопросов о проблеме с ssl-сертификатами. Но в CK api таких настроек нет.
Вот мой app.props:
spring.kafka.bootstrap-servers=omnibus-01.srvs.cloudkafka.com:9094,omnibus-02.srvs.cloudkafka.com:9094,omnibus-03.srvs.cloudkafka.com:9094
spring.kafka.properties.security.protocol=SASL_SSL
spring.kafka.properties.sasl.mechanism=SCRAM-SHA-256
spring.kafka.properties.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="Myusername" password="Mypassword";
И то, что я нашел в других темах, от парней, которые используют брокер и клиент Kafka без Cloud Karafka. Это ключ к моей проблеме? А как создать траст-хранилище и хранилище ключей, чтобы указать его местоположение?
Заранее огромное спасибо!
# SSL
spring.kafka.properties.[security.protocol]=SSL
spring.kafka.ssl.trust-store-location=guest.truststore
spring.kafka.ssl.trust-store-password=123456
spring.kafka.ssl.key-store-password=123456
spring.kafka.ssl.key-store-location=guest.keystore
spring.kafka.ssl.key-password=123456