diff --git a/clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java b/clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java index 2e2b97dfe37ba..f806cce692073 100644 --- a/clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java +++ b/clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java @@ -492,16 +492,6 @@ public static MemoryRecordsBuilder builder(ByteBuffer buffer, false, false, RecordBatch.NO_PARTITION_LEADER_EPOCH, maxSize); } - public static MemoryRecordsBuilder idempotentBuilder(ByteBuffer buffer, - Compression compression, - long baseOffset, - long producerId, - short producerEpoch, - int baseSequence) { - return builder(buffer, RecordBatch.CURRENT_MAGIC_VALUE, compression, TimestampType.CREATE_TIME, - baseOffset, System.currentTimeMillis(), producerId, producerEpoch, baseSequence); - } - public static MemoryRecordsBuilder builder(ByteBuffer buffer, byte magic, Compression compression, diff --git a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetchRequestManagerTest.java b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetchRequestManagerTest.java index 0f83e28d9e4d8..1475cef20db8b 100644 --- a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetchRequestManagerTest.java +++ b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetchRequestManagerTest.java @@ -872,7 +872,8 @@ public void testFetcherIgnoresControlRecords() { int partitionLeaderEpoch = 0; ByteBuffer buffer = ByteBuffer.allocate(1024); - MemoryRecordsBuilder builder = MemoryRecords.idempotentBuilder(buffer, Compression.NONE, 0L, producerId, + MemoryRecordsBuilder builder = MemoryRecords.builder(buffer, RecordBatch.CURRENT_MAGIC_VALUE, Compression.NONE, + TimestampType.CREATE_TIME, 0L, System.currentTimeMillis(), producerId, producerEpoch, baseSequence); builder.append(0L, "key".getBytes(), null); builder.close(); diff --git a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java index b85daebb8d899..07bf55dec9866 100644 --- a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java +++ b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java @@ -811,7 +811,8 @@ public void testFetcherIgnoresControlRecords() { int partitionLeaderEpoch = 0; ByteBuffer buffer = ByteBuffer.allocate(1024); - MemoryRecordsBuilder builder = MemoryRecords.idempotentBuilder(buffer, Compression.NONE, 0L, producerId, + MemoryRecordsBuilder builder = MemoryRecords.builder(buffer, RecordBatch.CURRENT_MAGIC_VALUE, Compression.NONE, + TimestampType.CREATE_TIME, 0L, System.currentTimeMillis(), producerId, producerEpoch, baseSequence); builder.append(0L, "key".getBytes(), null); builder.close();