Describe the bug
Consumer code:
Consumer consumer = getClient().newConsumer(Schema.STRING)
.topic("persistent://public/default/test-string2")
.subscriptionType(SubscriptionType.Shared)
.subscriptionName("my-subscription32")
.enableRetry(true)
.deadLetterPolicy(DeadLetterPolicy.builder()
.maxRedeliverCount(3)
.build())
.subscribe();
I created two non-partitioned topics: test-string2, test-string3。
The name of the subscription is the same,allowAutoTopicCreation=true,and allowAutoTopicCreationType=non-partitioned,in broker, both consumers will write messages to my-subscription32-DLQ.
The automatically created topic formart is not: topic-subscriptionName-DLQ,it is subscriptionName-DLQ.
Describe the bug
Consumer code:
Consumer consumer = getClient().newConsumer(Schema.STRING)
.topic("persistent://public/default/test-string2")
.subscriptionType(SubscriptionType.Shared)
.subscriptionName("my-subscription32")
.enableRetry(true)
.deadLetterPolicy(DeadLetterPolicy.builder()
.maxRedeliverCount(3)
.build())
.subscribe();
I created two non-partitioned topics: test-string2, test-string3。
The name of the subscription is the same,allowAutoTopicCreation=true,and allowAutoTopicCreationType=non-partitioned,in broker, both consumers will write messages to my-subscription32-DLQ.
The automatically created topic formart is not: topic-subscriptionName-DLQ,it is subscriptionName-DLQ.