hazelcast Serialization problem

[ss-guvenc]

I want to save my bucket store to hazelcast.
My code snippet is illustrated below;

@service
public class RateLimiterServiceImpl implements IRateLimiterService {

@Value("${rate.limiter.capacity}")
private Integer capacity;

@Value("${rate.limiter.refill-interval}")
private Integer refillInterval;

private static IMap<String, BucketProxy> bucketCache;

private HazelcastProxyManager proxyManager;

@PostConstruct
void init() {
    ClientConfig clientConfig = new ClientConfig();
    ClientNetworkConfig networkConfig = clientConfig.getNetworkConfig();
    clientConfig.setClusterName("hello-world");
    networkConfig.addAddress("0.0.0.0:5701");
    HazelcastInstance hazelcastInstance = HazelcastClient.newHazelcastClient(clientConfig);
    bucketCache = hazelcastInstance.getMap("buckets");
    proxyManager = new HazelcastProxyManager(bucketCache);

    Config config = new Config();
    SerializationConfig serializationConfig = config.getSerializationConfig();
    int baseTypeIdNumber = 10000;
    HazelcastProxyManager.addCustomSerializers(serializationConfig, baseTypeIdNumber);
}

@Override
public Bucket resolveBucket(String apiKey) {
    return bucketCache.computeIfAbsent(apiKey, this::newBucket);
}

private BucketProxy newBucket(String apiKey) {
    BucketConfiguration configuration = BucketConfiguration.builder()
            .addLimit(Bandwidth.simple(capacity, Duration.ofMinutes(refillInterval)))
            .build();

    return proxyManager.builder().build(apiKey,configuration);
    //return Bucket.builder().addLimit(Bandwidth.classic(capacity, Refill.intervally(capacity, Duration.ofMinutes(refillInterval)))).build();
}

}

i received exception which is below

com.hazelcast.nio.serialization.HazelcastSerializationException: There is no suitable serializer for class io.github.bucket4j.distributed.proxy.DefaultBucketProxy
at com.hazelcast.internal.serialization.impl.AbstractSerializationService.serializerFor(AbstractSerializationService.java:518)
at com.hazelcast.internal.serialization.impl.AbstractSerializationService.toBytes(AbstractSerializationService.java:167)
at com.hazelcast.internal.serialization.impl.AbstractSerializationService.toBytes(AbstractSerializationService.java:154)
at com.hazelcast.internal.serialization.impl.AbstractSerializationService.toData(AbstractSerializationService.java:139)
at com.hazelcast.internal.serialization.impl.AbstractSerializationService.toData(AbstractSerializationService.java:127)
at com.hazelcast.client.impl.spi.ClientProxy.toData(ClientProxy.java:76)
at com.hazelcast.client.impl.proxy.ClientMapProxy.computeIfAbsentLocally(ClientMapProxy.java:2117)
at com.hazelcast.client.impl.proxy.ClientMapProxy.computeIfAbsent(ClientMapProxy.java:2103)
at com.....service.RateLimiterServiceImpl.resolveBucket(RateLimiterServiceImpl.java:58)
at com....component.RateLimitInterceptor.preHandle(RateLimitInterceptor.java:47)
at org.springframework.web.servlet.HandlerExecutionChain.applyPreHandle(HandlerExecutionChain.java:148)

Thanks

[vladimir-bukhtoyarov]

@ss-guvenc hello

Custom Hazelcast serializers are well tested https://github.com/vladimir-bukhtoyarov/bucket4j/blob/7.0/bucket4j-hazelcast-all/bucket4j-hazelcast/src/test/java/io/github/bucket4j/hazelcast/HazelcastWithCustomSerializersTest.java#L39 at least with Hazelcast 4.2

There are few questions:

• Did you use docker? If so, did you check that each Hazelcast docker node contains Bucket4j jars in classpath?
• Did you use standalone Hazelcast distribution or run cluster as a part of your application? If standalone cluster is used, did you check that each Hazelcast docker node contains Bucket4j jars in classpath?
• Did you use Springboot? There are special notes about interleaving of Hazelcast serialization and Springboot classloader HazelcastSerializationException with Hazelcast 4.2 and bucket4j 6.2.0 #162 (comment)

[ss-guvenc]

thx @vladimir-bukhtoyarov for your detailed response.

the problem is that Bucket4j jars are not in hazelcast classpath. as u mentioned above.

i fixed the problem using this docker command;

docker run
-e CLASSPATH="/opt/hazelcast/ext/*"
-v /local/bucked4j/ext:/opt/hazelcast/ext
-p:5701:5701 hazelcast/hazelcast:5.0.2