Cassandra集群连接中的多个endpoint
我想将配置文件中的多个Cassandraendpoint提供给我的Java应用程序。
例如：cassandra主机：“主机1，主机2”
我尝试了< code > addContactPoints(host)，但它不起作用。如果其中一个Cassandra节点关闭，我不希望我的应用程序关闭。
cluster = Cluster.builder()
.withClusterName(cassandraConfig.getClusterName())
.addContactPoints(cassandraConfig.getHostName())
.withSocketOptions(new SocketOptions().setConnectTimeoutMillis(30000).setReadTimeoutMillis(30000))
.withPoolingOptions(poolingOptions).build();
共有1个答案
java驱动程序对其中一个不可用的接触点具有弹性。接触点用于建立初始连接[*]。只要驾驶员能够与一个接触点通信，就应该能够查询＜code＞系统。对等和系统。本地表以发现集群中的其余节点。
*它们也被添加到集群中的初始主机列表中，但通常提供的接触点映射到系统中的节点。对等表。
-
我的第二个问题是：是否需要？我将来可能会添加更多的节点。
-
我试图在卡桑德拉的一小部分数据上运行一个火花工作。我手头有一个键的RDD（分区和集群列），我只想在这些键上运行我的作业。 我在BoundStatementBuilder上收到以下错误：19
-
我有一个Spring启动应用程序，它使用来自 Kafka 集群中某个主题（例如 topic1）的消息。这就是我的代码目前的样子。 现在我想从另一个Kafka集群中的不同主题开始消费。一种方法是为此创建另一个bean。但是有更好的方法吗？
-
我按照以下说明设置了一个多节点kafka集群。现在，如何连接到动物园管理员？在JAVA中，只连接一个来自生产者/消费者端的动物园管理员可以吗？或者有办法连接所有的动物园管理员节点吗？ 设置多节点阿帕奇动物园守护者集群 在集群的每个节点上，将以下行添加到文件kafka/config/zookeeper.properties中 在群集的每个节点上，在由 dataDir 属性表示的文件夹中创建一个名为
-
我有一个向spark独立单节点集群提交spark作业的maven scala应用程序。提交作业时，Spark应用程序尝试使用spark-cassandra-connector访问Amazon EC2实例上托管的cassandra。连接已建立，但不返回结果。一段时间后连接器断开。如果我在本地模式下运行spark，它工作得很好。我试图创建简单的应用程序，代码如下所示： SparkContext.Sca
-
目前我有一个Quarkus应用程序，它从一个Kafka话题消费，并在另一个Kafka话题上生产。它使用SmallRye反应消息传递。效果很好。由于外部更改，要在其上生成的主题和要从其消费的主题将在不同集群上的Kafka服务器上（并且不应该/不能组合在一个集群中）。 在这里添加一个服务器并没有帮助，它会尝试将数据传播到代理上，这不是我的本意。 是否可能连接到多个集群（可能每个主题设置一个服务器）？在