Skip to content

Commit 1a95cb7

Browse files
committed
Minor change to force another travis build
1 parent ee9fff7 commit 1a95cb7

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

benchmarks/record_batch_compose.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ def func(loops, magic):
5959
for _ in range(MESSAGES_PER_BATCH):
6060
key, value, timestamp = next(precomputed_samples)
6161
size = batch.append(
62-
timestamp=timestamp, key=key, value=value, headers=[])
62+
timestamp=timestamp, key=key, value=value)
6363
assert size
6464
batch.close()
6565
results.append(batch.buffer())

kafka/record/memory_records.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,7 @@ def __init__(self, magic, compression_type, batch_size):
128128
self._closed = False
129129
self._bytes_written = 0
130130

131-
def append(self, timestamp, key, value, headers):
131+
def append(self, timestamp, key, value, headers=[]):
132132
""" Append a message to the buffer.
133133
134134
Returns:

0 commit comments

Comments
 (0)