xiaotong.wang
xiaotong.wang
ERROR LOG 2021-12-04 04:15:34.634 [pulsar-io-4-4] ERROR i.s.pulsar.handlers.kop.KafkaRequestHandler - Caught error in handler, closing channel java.lang.NoClassDefFoundError: io/streamnative/pulsar/handlers/kop/utils/delayed/DelayedOperationKey$GroupKey at io.streamnative.pulsar.handlers.kop.coordinator.group.GroupCoordinator.unsafeJoinGroup(GroupCoordinator.java:431) at io.streamnative.pulsar.handlers.kop.coordinator.group.GroupCoordinator.lambda$doJoinGroup$2(GroupCoordinator.java:283) at io.streamnative.pulsar.handlers.kop.utils.CoreUtils.inLock(CoreUtils.java:35) at io.streamnative.pulsar.handlers.kop.coordinator.group.GroupMetadata.inLock(GroupMetadata.java:214) at io.streamnative.pulsar.handlers.kop.coordinator.group.GroupCoordinator.doJoinGroup(GroupCoordinator.java:283) at io.streamnative.pulsar.handlers.kop.coordinator.group.GroupCoordinator.lambda$handleJoinGroup$0(GroupCoordinator.java:241) at java.util.Optional.map(Optional.java:215)...
## Describe a topic you want to learn (required) 1、安全设计上，有无可能对标kafka，补齐SASL/SCRAM-SHA256/512? 2、pulsar配置项实在有点多，有没有最佳实践例子，比如基于可靠性、基于高性能等 ## Why do you want to learn this topic? (required) 1、由于pulsar计算存储分离特性，一些业务考虑替换kafka 2、安全性上、可靠性上，要做哪些必要的加固 ## Reference (optional) https://github.com/apache/pulsar/issues/8670