You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
IN PIP-13 and its following PRs: #1103, We have made TopicsConsumerImpl behaviour similar to PartitionedConsumerImpl, This issue is tracking the following work to make dup TopicsConsumerImpl and PartitionedConsumerImpl.
The text was updated successfully, but these errors were encountered:
I would suggest to just rename PartitionedConsumerImpl, change the constructor to accept a list of topics (rather than the number of partitions) and switch to use TopicMessageIdImpl. I don't think that UnAckedMessageTracker usage would need to be changed.
That would avoid to add a lot of new code and having to merge it later.
IN PIP-13 and its following PRs: #1103, We have made TopicsConsumerImpl behaviour similar to PartitionedConsumerImpl, This issue is tracking the following work to make dup TopicsConsumerImpl and PartitionedConsumerImpl.
The text was updated successfully, but these errors were encountered: