使用redis对kafka事件应用锁,这样同一个kafka活动就不会被多个pod处理。
java.lang.IollegalStateException:没有在同步任何从属服务器
org.redison.RedisonBaseLockLambda$evalWriteAsync$0(RedisonBaselock.java:225)
位于java.util.concurrent.CompletableFuture.uniHandle(未知源)
位于java.util.concurrent.CompletableFuture$UniHandle.tryFire(未知
来源)
java.util.concurrent.CompletableFuture.postComplete(未知源)
位于java.util.concurrent.CompletableFuture.complete(未知源)
在
org.redison.command.CommandBatchServiceLambda$executeSync$7(CommandBatchService.java:322)
位于java.util.concurrent.CompletableFuture.uniWhenComplete(未知
来源)
java.util.concurrent.CompleteFuture$UniWhenComplete.tryFire(未知
来源)
java.util.concurrent.CompletableFuture.postComplete(未知源)
位于java.util.concurrent.CompletableFuture.complete(未知源)
在
org.redison.command.RRedisCommonBatchExecutor.handleResult(RedisCommon_Batchexecutor.java:163)
在
org.redison.command.RRedisExecutor.checkAttemptProise(RedisExecutar.java:524)
在
org.redison.command.RRedisExecutor.lambda$execute$4(RedisExecutar.java:176)
位于java.util.concurrent.CompletableFuture.uniWhenComplete(未知
来源)
java.util.concurrent.CompleteFuture$UniWhenComplete.tryFire(未知
来源)
java.util.concurrent.CompletableFuture.postComplete(未知源)
位于java.util.concurrent.CompletableFuture.complete(未知源)
在
org.redison.client.handler.CommandDecoder.decodeCommandBatch(CommandDecoder.java:318)
在
org.redison.client.handler.CommandDecoder.decodeCommand(CommandDecoder.java:210)
在
org.redison.client.handler.CommandDecoder.decode(CommandDecoder.java:137)
在
org.redison.client.handler.CommandDecoder.decode(CommandDecoder.java:113)
在
io.netty.hhandler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:510)
在
io.nety.handler.codec.ReplayingDecoder.callDecode(ReplayingDecoder.java:366)
在
io.netty.hhandler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:279)
在io.nety.channel.摘要。。。
