You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "chia7712 (via GitHub)" <gi...@apache.org> on 2025/04/30 13:41:07 UTC
Re: [PR] KAFKA-19146: Merge OffsetAndEpoch from raft to server-common [kafka]
chia7712 commented on code in PR #19475:
URL: https://github.com/apache/kafka/pull/19475#discussion_r2068692504
##########
server-common/src/main/java/org/apache/kafka/server/common/OffsetAndEpoch.java:
##########
@@ -16,40 +16,11 @@
*/
package org.apache.kafka.server.common;
-public class OffsetAndEpoch {
- private final long offset;
- private final int leaderEpoch;
-
- public OffsetAndEpoch(long offset, int leaderEpoch) {
- this.offset = offset;
- this.leaderEpoch = leaderEpoch;
- }
-
- public long offset() {
- return offset;
- }
-
- public int leaderEpoch() {
- return leaderEpoch;
- }
-
- @Override
- public boolean equals(Object o) {
- if (this == o) return true;
- if (o == null || getClass() != o.getClass()) return false;
- OffsetAndEpoch that = (OffsetAndEpoch) o;
- return offset == that.offset && leaderEpoch == that.leaderEpoch;
- }
-
- @Override
- public int hashCode() {
- int result = leaderEpoch;
- result = 31 * result + Long.hashCode(offset);
- return result;
- }
-
+public record OffsetAndEpoch(long offset, int leaderEpoch) implements Comparable<OffsetAndEpoch> {
Review Comment:
Maybe we can rename `leaderEpoch` to `epoch` for minimum change?
--
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: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org