如何将Apache Ignite瘦客户端连接到Apache Ignite集群？
我有一个正在运行的Ignite集群，并且我使用AWS S3进行节点发现：
TcpDiscoveryS3IpFinder ipFinder = new TcpDiscoveryS3IpFinder();
BasicAWSCredentials awsCredentials =
new BasicAWSCredentials(igniteAccessKey, igniteSecretAccessKey);
ipFinder.setAwsCredentials(awsCredentials);
ipFinder.setBucketName(igniteBucketName);
ipFinder.setBucketEndpoint("s3.eu-central-1.amazonaws.com");
TcpDiscoverySpi spi = new TcpDiscoverySpi();
spi.setIpFinder(ipFinder);
IgniteConfiguration cfg = new IgniteConfiguration();
cfg.setClientMode(true);
cfg.setDiscoverySpi(spi);
Ignition.start(cfg);
它工作得很好，我可以使用Apache Ignite Client节点连接到这个集群。
ClientConfiguration cfg = new ClientConfiguration().setAddresses("127.0.0.1:10800");
try (IgniteClient client = Ignition.startClient(cfg)) {
ClientCache<Integer, String> cache = client.cache("myCache");
// Get data from the cache
}
-
null
共有1个答案
您可以使用域名和IP地址。但不能将节点发现用于瘦客户端。
-
我已经在CentOS上安装了SQLPLUS瘦客户端。通过客户端，我试图与Oracle 12c建立TCPS连接。但是当我使用以下命令时，我得到“ORA-28759：打开文件失败”异常。然而，当我使用传输控制协议时，它工作正常。 这不起作用：sudo-sqlplus-s“user/pwd002@（描述=（地址=（协议=TCPS）（端口=1522）（主机=test.co.uk））（连接数据=（服务名称=
-
我正在尝试使用apache-spark读取和写入Ignite集群，我可以使用JDBC瘦客户机，但不是本机方法，正如几个spark+Ignite示例中提到的那样。 现在，所有的spark+ignite示例都启动了一个本地ignite集群，但我希望我的代码作为客户端连接到已经存在的集群。 完整代码：-（sparkDSLExample）函数无法使用thin连接ignite远程群集 示例-default.
-
kubectl get Pods-N队列-前门 客户端XML SpringConfig文件
-
我正在尝试使用Apache Camel和Qpid JMS客户端连接到在两个不同节点（VM）中运行的ActiveMQ Artemis主动-主动集群。我正在使用ActiveMQ Artemis 2.17.0。 我正在试图找出我的组织的远程URI配置应该是什么。阿帕奇。qpid。jms。JmsConnectionFactory实例。使用<代码>ampq://host1:5672,ampq://host2
-
我试图编写一个简单的spark应用程序，当我在本地运行它时，它可以将主程序设置为
-
我想在由安全kafka集群的kafka主题支持的Flink SQL表上执行一个查询。我能够以编程方式执行查询，但无法通过Flink SQL客户端执行。我不知道如何通过Flink SQL客户端传递JAAS配置（）和其他系统属性。 FlinkSQL以编程方式查询 这很好。 通过SQL客户端Flink SQL查询 运行此命令将导致以下错误。 中没有任何内容，除了以下注释 SQL客户端运行命令 Flink