HOTFIX: Compilation error in GroupMetadataManagerTest
Accidentally broke after merging which had not been updated for
Reviewers:Matthias J. Sax
@@ -29,7 +29,7 @@ import org.apache.kafka.clients.consumer.internals.PartitionAssignor.Subscriptio
import org.apache.kafka.common.TopicPartition
import org.apache.kafka.common.protocol.Errors
import org.apache.kafka.common.record._
-import org.apache.kafka.common.requests.{IsolationLevel, OffsetFetchResponse}
+import org.apache.kafka.common.requests.OffsetFetchResponse
import org.apache.kafka.common.requests.ProduceResponse.PartitionResponse
import org.easymock.{Capture, EasyMock, IAnswer}
import org.junit.Assert.{assertEquals, assertFalse, assertNull, assertTrue}
@@ -1799,8 +1799,11 @@ class GroupMetadataManagerTest {
val logMock = EasyMock.mock(classOf[Log])
EasyMock.expect(logMock.logStartOffset).andReturn(startOffset).anyTimes()
- EasyMock.expect(logMock.read(EasyMock.eq(startOffset), EasyMock.anyInt(), EasyMock.eq(None),
- EasyMock.eq(true), EasyMock.eq(IsolationLevel.READ_UNCOMMITTED)))
+ EasyMock.expect(logMock.read(EasyMock.eq(startOffset),
+ maxLength = EasyMock.anyInt(),
+ maxOffset = EasyMock.eq(None),
+ minOneMessage = EasyMock.eq(true),
+ includeAbortedTxns = EasyMock.eq(false)))
.andReturn(FetchDataInfo(LogOffsetMetadata(startOffset), mockRecords))
EasyMock.expect(replicaManager.getLog(groupMetadataTopicPartition)).andStubReturn(Some(logMock))
EasyMock.expect(replicaManager.getLogEndOffset(groupMetadataTopicPartition)).andStubReturn(Some(18))
