Hazelcast中基于时间的逐出
我正在满足一个要求，即我需要在群集中运行N个hazelcast实例，并且在所有实例上都需要kafka使用者. 现在要问的是，kafka上出现的每条消息都应添加到分布式地图，并且条目必须每20秒逐出一次，这是我通过结合使用生存时间和max-idle seconds参数来完成的在地图配置中. 但是我真正想要的是，当逐出条目时，只有一个节点应该处理它，现在，将逐出逐项通知所有节点. 让
..
hazelcast相关内容
创建一个新的Jet自定义分区程序
我的用例要求从Kafka主题中读取消息，并按照发布到Kafka中的自然顺序处理消息. Kafka生产者负责发布按单个kafka主题分区排序的每组消息，而我需要以相同的顺序在同一Vertex-Processor中处理每组消息. 上面的图像代表了基本思想.有一些从Kafka读取的KafkaSource-Processors. 并且一条边连接到顶点以解码kafka消息等. 我可以
..
hazelcast-读取备份数据与近缓存
在IMap配置中，可以将属性read-backup-data设置为true，如果密钥的所有者是其他成员，则该成员可以从备份副本中读取值(如果可用). http ://docs.hazelcast.org/docs/latest-development/manual/html/Distributed_Data_Structures/Map/Backing_Up_Maps.html#page_E
..
Mapstore无法从数据库Hazelcast加载数据
我正在使用Hazelcast和mysql. 我在mysql中为我的表创建了一个mapstore.我想做的是从数据库中使用map.loadAll填充数据.我的地图商店的实现是 public class CityMapStore implements MapStore { private final Connection con; public
..
Hazelcast:添加索引时出现问题
我有一个hazelcast实例，其键的类型为MyObject，值是一个枚举. 假设MyObject类的属性之一是date，其类型为java.sql.Date. class MyObject { private Date date; public Date getDate() { return date; } p
..
带有嵌入式vertx的Spring Boot Webapp无法启动
我正在尝试使用嵌入式集群式vertx启动Spring Boot webapp(可执行的war). 它失败，但出现以下异常. java.lang.IllegalArgumentException: PortableFactory[-14] is already registered! com.hazelcast.concurrent.countdownlatch.client.CountDow
..
Openshift V2-自定义墨盒权限被拒绝打开端口
我正在尝试在开放班次的端口上侦听，但是我被拒绝了权限.我正在使用Wildfly 8.2.1墨盒的叉子: 2016-12-31 13:24:06,016 INFO [com.hazelcast.instance.DefaultAddressPicker] (MSC service thread 1-8) [LOCAL] [name] [3.5.4] Interfaces is disable
..
使用完全相同的代码，高频hazelcast环形缓冲区客户端未更新，但低频客户端已更新
我有以下代码用于侦听各种环形缓冲区.一些是高频价格数据，一些是低频交易数据: public static void main(String[] args) { HazelcastInstance client = Hazelcast.newHazelcastInstance(); Ringbuffer databuffer = clie
..
getAsync("key").get(timeout，sec)不等待，返回null
Hazelcast 3.4.4. 我遇到了无论如何map.getAsync返回null的情况.即使超时设置为10000000，TimeUnit.SECONDS，它也不会等待. 但是，如果我将Thread.sleep(10000)放在getAsync之前，那么它将从映射返回正确的值. 我想知道怎么了?如何检查/修复/理解它? UPDATE :如果我从代码和所有依赖项(如Scala.
..
Hazelcast是否在缓存中支持基于JSON的对象?
如主题中所示:我找不到任何好的信息，Hazelcast是否可以支持将JSON对象存储为缓存数据?如果可以的话，是否允许基于某些类似于JSONPath/JPQL/SQL的表达式来查询此类对象? 我可以看到Apache Geode(GemFire)确实支持以下功能: http://geode-docs.cfapps.io/docs/developing/data_serialization/js
..
Hazelcast Spring(引导)JPA-保存新实体
我有一个使用JPA的现有客户端/服务器，Spring启动项目.我遵循了 spring -data-jpa-hazelcast-migration 示例来创建Hazelcast客户端&服务器.数据库中存在现有数据，用于填充Hazelcast地图.这些数据库条目中的每一个都有一个Integer ID，该ID成为Map键.在服务器上的loadAllKeys()期间，我填充一个由Hazelcast分发/管
..
在Hazelcast中存储和过滤键值列表
我的数据库调用返回一个键的值列表，我需要在弹簧中使用Hazelcast作为缓存来存储这些值. 我能够将其存储为IMap中的(键，列表)，但是这样做无法使用诸如Hazelcast的谓词之类的东西在这些项上应用过滤器.我还希望它支持分页显示值列表. 已经听说过有关MultiMaps的内容，但无法在springboot中进行配置，也不确定是否符合上述用例. 在此方面的任何帮助都将受到高
..
为什么hazelcast无法使用imap查询不正确的结果，并且hazelcastjsonvalue包含汉字?
当我将hazelcast存储数据与imap和hazelcastjsonvalue一起使用时，我无法在sql之类的"side ='1'".我想是因为json包含像“国债"之类的汉字.如何解决这个问题?如果可以设置hazelcast的某些配置以支持汉字.这样的代码，System.out.println()结果为{}，应包含json: Gson gson = new Gson(); String
..
在Java中对Hazelcast json值进行排序
我将Hazelcast JSON值存储在IMAP中 IMap.put(Integer,new HazelcastjsonValue("{"id":"001","name":"vikram"}")); IMap.put(Integer,new HazelcastjsonValue("{"id":"002","name":"abhishek"}")); 如何按name 对Hazelcast
..
可以在EKS/AWS中选举Hazelcast主节点吗?
我们有一个在物理设备中运行的spring boot应用程序.计划迁移到EKS(AWS).我们将hazelcast用于以下多个目的. 是否可以在AWS中使用hazelcast本身来利用相同的功能?? 还是我应该使用除hazelcast本身以外的任何其他技术? Hazelcast用于: 1.(机器的)主选举 2.缓存(有时保留一些文件，并且主要保留给websocket消息，并在需要时
..
Spring Webflux会话管理
我正在使用Spring boot 2，并在netty上运行spring webflux. 我想添加会话管理而不需要支持数据库或Redis服务器(因此Spring Session在这里似乎不是解决方案). 我可以在控制器中使用WebSession，但随后需要在负载均衡器上启用粘性会话，而我希望避免这种情况. 我想要的是以下之一: 类似于Play框架的客户端会话(会话存储为co
..
Hazelcast-无法进行远程呼叫:ContainsKeyOperation
错误纯粹是标题.我对从Hazelcast检索到的地图中的containsKey所做的任何调用都收到此特定错误.下面的示例: val structuresMapStore : IMap[ String, Object ] = instance.getMap( MapNames.Structures ) if ( structuresMapStore.containsKey( uuidModel
..
用于node.js的hazelcast客户端模块
在我的Node.js应用程序中，我想连接Hazelcast节点实例并访问Hazelcast Node的队列/哈希图.有没有可用的node.js模块来执行此操作. 谢谢. 解决方案 一年多以前，有人问过这个问题，但有些事情已经改变. Hazelcast Node.js客户端实际上确实存在，并且目前提供以下功能 地图 获取 放入 删除 智能客户端-客户端连接到每个群集节
..
Hazelcast便携式序列化
我想对存储在IMap中的对象使用Portable序列化以实现: 在插入过程中快速索引(不反序列化对象和 反射) 类演化(版本控制) 是否可以在不实现Portable接口的情况下存储我的类? 是否可以存储不能实现Portable接口的第三类方，例如Date或BigDecimal(或具有嵌套结构)? 解决方案 您可以使用Portable来实现快速索引编制，是的.在查询未索引
..
更改hazelcast地图的加载模式
我正在尝试更改Hazelcast 3.2地图的加载模式.这是我通过代码尝试过的(不确定是否可以通过XML配置文件使用它，这对我来说更合适). private InitialLoadMode initialLoadMode = InitialLoadMode.EAGER; final Config config= new Config(); final MapConfig mapConfig
..