2

在此处输入图像描述

所以在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);
4

1 回答 1

0

所以我想出了我使用Kafka-rest-proxyConfluent 提供的解决方案,我用它配置了它,AWS MSK它对我有用

于 2020-05-18T06:02:48.520 回答