Внедрение SSL на Spring-kafka Consumer - PullRequest
Новая
       7

Внедрение SSL на Spring-kafka Consumer

2 голосов
/ 29 апреля 2020

Я использую ниже конфиги на моей фабрике контейнеров. После того, как я добавлю этот конфиг, я не смогу увидеть что-либо потребляемое потребителем spring-kafka. Есть ли стандартный способ настройки SSL для потребителя кафки с помощью Spring. Когда я удаляю эти конфиги, я могу получать сообщения и потреблять их. 

config.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SSL")
config.put("ssl.keystore.location", "location_to/abc.keystore.jks"); //
config.put("ssl.keystore.password", "pwd1122");
config.put("ssl.truststore.location", "location_to/serv.truststore.jks");
config.put("ssl.truststore.password", "pwd11223");

1 Ответ

1 голос
/ 29 апреля 2020

Когда я удаляю эти конфиги, я могу получать сообщения и потреблять их.

Это просто означает, что брокер не настроен для SSL - клиент и сервер должны согласиться использовать SSL или нет.

Если посредник настроен с прослушивателем SSL, он должен быть на другом порту.

...