Yunze Xu
> /namespace/pulsar/kj-kop/kj-kop-broker-0.kj-kop-broker-headless.sndev.svc.cluster.local:8080/0x00000000_0xffffffff is already locked @codelipenghui It looks like the broker failed to call `NamespaceService#registerNamespace` on the heartbeat namespace like the same issue we have seen in the AoP test....
Using a simple `grep` we can see ```bash $ find kafka-impl/src/main -name "*.java" | xargs grep -n "\.join()" kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaTopicManager.java:86: future.join().deleteExpiredCursor(current, expirePeriodMillis); kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/transaction/TransactionStateManager.java:818: producer.join().getTopic()); kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/transaction/TransactionStateManager.java:826: reader.join().getTopic()); kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/group/GroupMetadataManager.java:820: metadataConsumer.join().getTopic()); kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/group/GroupMetadataManager.java:826: metadataConsumer.join().getTopic(), message.getMessageId());...
Here are the list of the `get()` calls except those are used only in tests. ### 1. KafkaProtocolHandler#initTransactionCoordinator ```java transactionCoordinator.startup(kafkaConfig.isEnableTransactionalIdExpiration()).get(); ``` ### 2. KafkaRequestHandler#validateTenantAccessForSession ```java Boolean granted = authorize(AclOperation.ANY, Resource.of(ResourceType.TENANT,...
Just a term correction. In Kafka, LSO is usually short for Last Stable Offset. For log started offsets, there seems to be no short name. To solve this problem, I...
Bad version number: - **2.9.2.1 to 2.9.2.4** (to be updated...): they are actually guaranteed to be compatible with Pulsar 2.9.1 - **2.9.2.1**: It's actually the same with 2.9.1.1 Releases that...
@eolivelli Yes, not like Pulsar proxy, Envoy acts more like a sidecar. Currently we have no proxy for KoP like Pulsar proxy.
@eolivelli It would be great to have protocol handlers support in the Pulsar Proxy.
Is the dependency upgrade necessary? I found we have already cherry-picked many transaction related PRs to branch-2.8.1. I'm wondering if it could be supported with older Kafka dependency. Or is...
Got it. I think we should keep the Kafka dependency of branch-2.8.1 not changed. And the producer fence feature won't be supported for KoP 2.8.x, while the other transaction features...
Which KoP version and Pulsar version did you use?