lordcheng10 edited a comment on pull request #14970:
URL: https://github.com/apache/pulsar/pull/14970#issuecomment-1084941600
I think we also need to implement a method similar to isSuccessorTo to
determine whether the consumer can be overridden, what do you think? @lhotari
@michaeljmarshall @eolivelli
like this:
public boolean isSuccessorTo(Consumer other){
return Objects.equals(cnx.clientAddress(),
other.cnx.clientAddress()) && consumerId == other.consumerId
&& other.consumerEpoch < consumerEpoch;
}
--
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]