chia7712 commented on code in PR #18021:
URL: https://github.com/apache/kafka/pull/18021#discussion_r1874220951
##########
storage/src/main/java/org/apache/kafka/storage/internals/log/OffsetsOutOfOrderException.java:
##########
@@ -14,16 +14,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
-package kafka.common
+package org.apache.kafka.storage.internals.log;
/**
- * Indicates the follower or the future replica received records from the
leader (or current
- * replica) with first offset less than expected next offset.
- * @param firstOffset The first offset of the records to append
- * @param lastOffset The last offset of the records to append
+ * Indicates the follower received records with non-monotonically increasing
offsets
*/
-class UnexpectedAppendOffsetException(val message: String,
- val firstOffset: Long,
- val lastOffset: Long) extends
RuntimeException(message) {
+public class OffsetsOutOfOrderException extends RuntimeException {
Review Comment:
Could you please remove `OffsetsOutOfOrderException.scala`?
--
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]
