Skip to content

Commit e4fbf40

Browse files
committed
Fix two more typos
1 parent 0abe989 commit e4fbf40

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

clients/src/test/java/org/apache/kafka/clients/consumer/internals/CompletedFetchTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,7 @@ public void testAbortedTransactionRecordsRemoved() {
114114
@Test
115115
public void testCommittedTransactionRecordsIncluded() {
116116
int numRecords = 10;
117-
Records rawRecords = newTranscactionalRecords(ControlRecordType.COMMIT, numRecords);
117+
Records rawRecords = newTransactionalRecords(ControlRecordType.COMMIT, numRecords);
118118
FetchResponseData.PartitionData partitionData = new FetchResponseData.PartitionData()
119119
.setRecords(rawRecords);
120120
CompletedFetch completedFetch = newCompletedFetch(0, partitionData);
@@ -258,7 +258,7 @@ private Records newRecords(long baseOffset, int count, long firstMessageId) {
258258
}
259259
}
260260

261-
private Records newTranscactionalRecords(ControlRecordType controlRecordType, int numRecords) {
261+
private Records newTransactionalRecords(ControlRecordType controlRecordType, int numRecords) {
262262
Time time = new MockTime();
263263
ByteBuffer buffer = ByteBuffer.allocate(1024);
264264

0 commit comments

Comments
 (0)