You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/07/28 09:47:44 UTC

[GitHub] [pulsar] Johnnyhooyo opened a new issue #11474: Retry letter producer does not handle AUTO_CONSUME_SCHEMA

Johnnyhooyo opened a new issue #11474:
URL: https://github.com/apache/pulsar/issues/11474


   same as #9935 
   
   Describe the bug
   when using an auto consume schema together with dead letter policy, the retry letter producer fails to start with this exception:
   ConsumerImpl - Create retry letter producer exception with topic: retryTopic
   org.apache.pulsar.client.api.PulsarClientException$InvalidConfigurationException: AutoConsumeSchema is only used by consumers to detect schemas automatically
   
   **To Reproduce**
   Steps to reproduce the behavior:
   
   ![image](https://user-images.githubusercontent.com/35983936/127301649-b39bbb5d-c474-4329-8145-1959db9ac773.png)
   
   1. create consumer with Schema.AUTO_CONSUME with dead letter policy
   2. do consumer.reconsumeLaterAsync(message, 10, TimeUnit.SECONDS);
   3. then the exception appears.
   
   **Expected behavior**
   should it handled in the same way list #9935 to create retryLetterProducer?
   now:
   `this.retryLetterProducer = this.client.newProducer(this.schema).topic(this.deadLetterPolicy.getRetryLetterTopic()).enableBatching(false).blockIfQueueFull(false).create();`
   
   `this.deadLetterProducer = this.client.newProducer(Schema.AUTO_PRODUCE_BYTES(this.schema)).topic(this.deadLetterPolicy.getDeadLetterTopic()).blockIfQueueFull(false).createAsync();
   `
   


-- 
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.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

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

[GitHub] [pulsar] eolivelli commented on issue #11474: Retry letter producer does not handle AUTO_CONSUME_SCHEMA

Posted by GitBox <gi...@apache.org>.
eolivelli commented on issue #11474:
URL: https://github.com/apache/pulsar/issues/11474#issuecomment-888397212


   you are right.
   do you want to submit a patch ?
   please add a test cases that reproduces your problem 


-- 
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.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

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

[GitHub] [pulsar] Johnnyhooyo commented on issue #11474: Retry letter producer does not handle AUTO_CONSUME_SCHEMA

Posted by GitBox <gi...@apache.org>.
Johnnyhooyo commented on issue #11474:
URL: https://github.com/apache/pulsar/issues/11474#issuecomment-889051500


   the code almost like this:
   ```
   PulsarClient pulsarClient = PulsarClient.builder()
   		.serviceUrl("url")
   		.build();
   
   Consumer<GenericRecord> consumer  = pulsarClient
   		.newConsumer(Schema.AUTO_CONSUME())
   		.topic("topicName")
   		.subscriptionName("subName")
   		.subscriptionType(SubscriptionType.Shared)
   		.autoUpdatePartitions(true)
   		.receiverQueueSize(2000)
   		.subscribe();
   
   Message<GenericRecord> message = consumer.receive(10, TimeUnit.SECONDS);
   
   try {
   	//do something
   	throw new RuntimeException();
   } catch (Exception e) {
   	consumer.reconsumeLaterAsync(message, 10, TimeUnit.SECONDS);
   }
   ```
   
   and i will try to make a patch.


-- 
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.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

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

[GitHub] [pulsar] codelipenghui commented on issue #11474: Retry letter producer does not handle AUTO_CONSUME_SCHEMA

Posted by GitBox <gi...@apache.org>.
codelipenghui commented on issue #11474:
URL: https://github.com/apache/pulsar/issues/11474#issuecomment-1058887794


   The issue had no activity for 30 days, mark with Stale label.


-- 
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.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

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