无法连接到在spring boot上使用kafka编写mongodb
我正在运行一个spring boot应用程序，它会侦听IBM消息中心Kafka，然后将其存储到IBM云上的compose for mongoDB中。
在一起运行Kafka和Compose for MongoDB时，我遇到了一个与SSL证书相关的错误。
我正在为mongoDB证书使用compose并使用有效的信任存储和密钥。
如果我在Spring靴中使用嵌入式mongo，那么一切都很好。
到目前为止我设置的东西：
我在我的应用程序属性文件中设置了mongoDB URI的撰写，我在信任存储中传递了密钥密码作为运行java应用程序的VM参数。
错误：com.mongodb.MongoSocketWriteException：在com上发送消息时发生异常。mongodb。联系InternalStreamConnection。translateWriteException（InternalStreamConnection.java:518）~[mongodb-driver-core-3.6.3.jar:na]
共有1个答案
确保在jar之后传入信任存储和密码，如下面的java-jar-Djavax。网ssl。trustStore=此处为JKS\U-Djavax。网ssl。trustStorePassword=PASS\u HERE target/jarfilehere。罐子
-
我正在尝试使用zookeeper/kafka非集群设置，以便能够使用python脚本与容器对话。我希望能够运行一个zookeeper/kafka容器和2个或多个容器，其中包含与zookeeper-kafka通信的python脚本，所有这些容器都在Azure上的容器或容器组中运行。 为了测试这一点，我创建了下面的docker容器组，其中zookeeper和kafka作为2个服务，第3个服务启动一个简
-
我创建了一个docker compose文件，将MySql连接到SpringBoot应用程序。但我得到了这个错误： 我尝试在本地机器中使用docker默认ip运行Spring Boot应用程序，同时在这个docker-compose.yml文件中只运行MySql容器，结果运行得非常好。但当我尝试docker编写文件时。我知道这个错误。
-
我尝试了kafka-console-consumer.sh和kafka-console-producer.sh,它工作得很好。我能够看到生产者在消费者中发送的消息 1）我已经下载了s3连接器(https://docs.confluent.io/current/connect/kafka-connect-S3/index.html) 2）将文件解压缩到/home/ec2-user/plugins/
-
例外情况是： docker-compose文件是： 多克菲乌勒
-
当我启动创建器时，它总是尝试连接本地主机：9092，而不是配置的远程节点IP。 注意:我已经在远程节点的server.properties中定义了advertised.listeners。 还请PFB远程节点kafka代理服务器属性
-
使用SSL连接到Postgres时引发异常。 原因:javax.net.ssl.SSLException:收到致命警报:在sun . security . SSL . alerts . getsslexception(alerts . Java:208)在sun . security . SSL . alerts . getsslexception(alerts . Java:154)在sun .