Skip to content

Commit 6cd77c9

Browse files
committed
add comment about apache/pulsar#11553
1 parent 84fcdf0 commit 6cd77c9

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/transaction/PulsarStorageProducerIdManagerImpl.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -108,6 +108,8 @@ private synchronized void endReadLoop(CompletableFuture<?> handle) {
108108

109109
@Override
110110
public synchronized CompletableFuture<Long> generateProducerId() {
111+
// we could get rid of the Exclusive Producer if we had Message.getIndex()
112+
// introduced in 2.9.0 https://github.com/apache/pulsar/pull/11553
111113
CompletableFuture<Producer<byte[]>> producerHandle = pulsarClient.newProducer()
112114
.enableBatching(false)
113115
.topic(topic)

0 commit comments

Comments
 (0)