所以在aws实例上,我们尝试将spring kafka与msk连接起来,它与本地kafka一起工作。接下来没有 ssl 。我试过 telnet 它的运行。但是在运行应用程序时会出现此异常。
我们的 msk 集群在同一个 vpc 中。所有代理连接配置字符串都很好
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);