我的kafka-ignite连接器突然停止了，因为ignite服务器重启了。当我重新启动连接器时，它抛出了关于特定数据的亲和性节点的相同错误，它没有获得特定分区的节点详细信息。:754) at:754)
at org.apache.i
浏览 122提问于2021-09-10得票数 0
1回答
kafka点火水槽连接器
、、、
我正在尝试将数据从Kafka topic复制到apache ignite集群。我已经在插件中添加了ignite-core.jar以及所有其他所需的文件，并根据日志将其加载到连接器中。INFO Instantiated connector string-ignite-connector with version 6.1.1-ccs of type class org.apache.ignite.stream.kafka.connect.
浏览 30提问于2021-05-15得票数 1
我正在尝试对Kafka消息流进行流处理和CEP。为此，我选择了Apache Ignite来首先实现一个原型。但是，我无法连接到队列：bin/zookeeper-server-start.sh config有谁知道怎么解决这个问题吗？401) ~ignite-core-1.8.0.jar:1.8.0在org.ap
浏览 0提问于2017-02-23得票数 1
回答已采纳
目前我在InteliJ中有POM文件，大部分-它可以识别所有的Apache Ignite依赖，但不能识别Kafka依赖。 <!-- Apache Ignite dependencies --> <groupId>org.apache.ignite</groupId>
<<groupId>org.apac
浏览 3提问于2017-08-15得票数 0
1回答
我正在尝试使用Ignite-Spark插件启动一个Ignite上下文，用于Ignite版本2.2.0。true)IgniteException: Failed to load class names properties file packaged with ignitebinaries ldr=org.apache.spark.util.MutableURLClass
浏览 0提问于2018-03-02得票数 1
回答已采纳
2回答
ignite = Ignition.start();
// Set a few key parameters); settings.put("key.serializer", "org.apache.kafka.common.seria
浏览 1提问于2017-03-03得票数 0
1回答
我正在尝试使用CSV设置Kafka流，这样我就可以将其流式传输到Spark中。jre8"
libraryDependenc
浏览 0提问于2018-06-22得票数 4
回答已采纳
我正在尝试在EC2 (CentOS)上安装Apache Ignite。已下载最新的Ignite src (2.0)并安装了Java 1.8和MVN。:ignite-parent:1, /home/ec2-user/ignite/apache-ignite-2.0.0-src/parent/pom.xml, line 29, column 13
@:apache-ignite
浏览 2提问于2017-06-05得票数 0
在内存和postgres…之间的开箱即用的开源集成 我相信我们可以用阿帕奇ignite..can做，你能告诉我怎么做吗？或任何其他使用Postgres的内存解决方案 grid gain和apache ignite有什么不同？
浏览 22提问于2020-09-23得票数 0
1回答
1个servers节点正在由kafka连接器进程运行。 客户端不能向kafka连接器触发节点发送任何消息。(GridIoMessageFactory.java:1106) at org.apache.ignite.internal.managers.
浏览 19提问于2020-11-05得票数 0
我正在尝试在我的sbt项目中使用ignite-spark依赖。+= "org.xerial.snappy" % "snappy-java" % "1.1.4"libraryDependencies +=
浏览 0提问于2017-10-06得票数 1
现在，所有星星之火+点燃示例启动一个本地点燃集群，但我希望我的代码作为客户端连接到已经存在的集群。问题：-package com.ignite.examples.spark
浏览 0提问于2019-10-17得票数 0
回答已采纳
我在我的应用程序中使用flink作为流处理器，我想将结果转储到位于远程服务器上的apache ignite中。在ignite.xml的TcpDiscoverySpi部分，我指定了ignite服务器的ip地址；但是，到服务器的任何连接都不会稳定。<dependency> <artifactId>
浏览 41提问于2021-03-12得票数 0
回答已采纳
2回答
我创建了一个AKS，并在上面部署了Apache服务。当我检查吊舱时，我可以看到它们在工作。另外，我可以得到负载平衡器IP。 }
System.AggregateException：“未能建立Ignite内部异常ExtendedSocketExcep
浏览 3提问于2021-07-29得票数 0
回答已采纳
我想将我的Kafka主题数据复制到ignite节点。但情况是Kafka服务器运行在AWS实例上，而Ignite运行在我的机器上。
浏览 2提问于2021-05-14得票数 1
我正试图通过Kubernetes环境中的瘦客户机使用Ignite和我的java应用程序来设置一个分布式缓存。ClientConfiguration cfg = new ClientConfiguration()
.setAddr
浏览 3提问于2019-09-23得票数 2
我已经在ignite目录中运行了example-cache示例，如下所示：我之前已经将IGNITE_HOME环境变量设置为
D:\work\tools\apache ignite1.9.0\ap
浏览 2提问于2017-04-04得票数 2
connect jdbc:ignite:thin://127.0.0.1/ '' '' org.apache.ignite.IgniteJdbcThinDriverConnected to: Apache Ignite (version 2.3.0#20171028-sha1:8add7fd5)
Dr
浏览 2提问于2018-02-10得票数 3
我的问题是Apache Ignite现在有了putAsync()方法，它实际上是如何将我的数据排入队列的？它会进入内存吗？它是否会写入磁盘上的日志？一旦我的数据完成后，它是如何从未来进入数据库的？例如，Kafka，当你想发送数据时，你需要调用producer.send()，它是异步的，我相信Kafka会将你的请求放入一个缓冲区，后台线程会通过网络刷新该缓冲区。因此，对于Kafka，我知道有另一个线程在后台刷新数据&根据缓冲区大小，我可以进行多少异步调用是有限制的。 我正在为<em
浏览 32提问于2021-01-14得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
