Проблема соединения с мск с помощью пружинной кафки - PullRequest
2 голосов
/ 21 апреля 2020

enter image description here

Итак, здесь в экземпляре aws мы попытались соединить пружинную кафку с msk, где она работает с локальной кафкой. рядом нет ssl. Я попытался te lnet его запустить. Но при запуске приложения это исключение наступает.

Наш кластер msk находится в том же vp c. все строки конфигурации соединения с брокером в порядке

  Map<String, Object> configProps = new HashMap<>();
        configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, env.getProperty("spring.kafka.producer.bootstrap-servers"));
        configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
...