The main reason for this error is that the message listener for TopicsConsumer was also set for individual sub-consumerImpl. In above calling stack, when time-out, TopicsConsumer.UnAckedMessageTracker will let sub-consumerImpl to redeliver messages.
[ Full content available at: https://github.com/apache/incubator-pulsar/issues/2574 ] This message was relayed via gitbox.apache.org for [email protected]
