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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to