[GitHub] [pulsar] mlyahmed commented on issue #9585: The consumer doesn't reconnect to the multi partitioned topic after the topic deletion and recreating

[GitBox <gi...@apache.org>]

mlyahmed commented on issue #9585:
URL: https://github.com/apache/pulsar/issues/9585#issuecomment-778834699


   Hi,
   
   Could you please share more about the way you’ve proceeded? and the version you’ve used ?
   
   Actually I created a partitioned topic through the cli let’s say :
   `pulsar-admin topics create-partitioned-topic persistent://public/default/issue-9585  -p 3`
   
   Created a consumer with the minimum options: topic + subscriptionName:
   `pulsar-client consume -s ahmed -n 0 persistent://public/default/issue-9585`
   
   When I deleted the topic without the force flag, -f,  I got an error explaining that there is a current active procuder/subscription.
   
   When I delete the topic with the force flag, -f, the topic is deleted. The consumer resubscribes to new topics with the same names as the previous partitions:
   
   ```
   19:55:43.580 [pulsar-client-io-1-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/default/issue-9585-partition-1][ahmed] Subscribed to topic on localhost/127.0.0.1:6650 -- consumer: 1
   19:55:43.589 [pulsar-client-io-1-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/default/issue-9585-partition-0][ahmed] Subscribed to topic on localhost/127.0.0.1:6650 -- consumer: 0
   19:55:43.595 [pulsar-client-io-1-1] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/default/issue-9585-partition-2][ahmed] Subscribed to topic on localhost/127.0.0.1:6650 -- consumer: 2
   ```
   
   And when I try to recreate the partitioned topic this error is thrown due the topics created by the consumer:
   
   ```
   9:55:48.317 [AsyncHttpClient-7-1] WARN  org.apache.pulsar.client.admin.internal.BaseResource - [http://localhost:8080/admin/v2/persistent/public/default/issue-9585/partitions] Failed to perform http put request: javax.ws.rs.ClientErrorException: HTTP 409 Conflict
   This topic already exists
   
   Reason: This topic already exists
   ```
   
   
   I’ve also tested with the Go client and ended up with the same issue. And also, the Go consumer fall in error due to the number of partitions changed:
   
   ```
   goroutine 85 [running]:
   github.com/apache/pulsar-client-go/pulsar.(*consumer).internalTopicSubscribeToPartitions(0xc000282300, 0x0, 0x0)
           /home/ahmed/tmp/pulsar/go-client/vendor/github.com/apache/pulsar-client-go/pulsar/consumer_impl.go:279 +0x890
   github.com/apache/pulsar-client-go/pulsar.newInternalConsumer.func1(0xc000282300)
           /home/ahmed/tmp/pulsar/go-client/vendor/github.com/apache/pulsar-client-go/pulsar/consumer_impl.go:238 +0xc8
   created by github.com/apache/pulsar-client-go/pulsar.newInternalConsumer
           /home/ahmed/tmp/pulsar/go-client/vendor/github.com/apache/pulsar-client-go/pulsar/consumer_impl.go:235 +0x2bc
   ```
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org