Skip to content

Commit 55fae64

Browse files
authored
Drop the mutable default in _estimate_size_in_bytes (#2865)
1 parent bf3330e commit 55fae64

2 files changed

Lines changed: 6 additions & 2 deletions

File tree

kafka/producer/kafka.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -664,7 +664,9 @@ def max_usable_produce_magic(cls, api_version):
664664
else:
665665
return 0
666666

667-
def _estimate_size_in_bytes(self, key, value, headers=[]):
667+
def _estimate_size_in_bytes(self, key, value, headers=None):
668+
if headers is None:
669+
headers = []
668670
magic = self.max_usable_produce_magic(self.config['api_version'])
669671
if magic == 2:
670672
return DefaultRecordBatchBuilder.estimate_size_in_bytes(

kafka/record/memory_records.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -162,11 +162,13 @@ def skip(self, offsets_to_skip):
162162
# Exposed for testing compacted records
163163
self._next_offset += offsets_to_skip
164164

165-
def append(self, timestamp, key, value, headers=[]):
165+
def append(self, timestamp, key, value, headers=None):
166166
""" Append a message to the buffer.
167167
168168
Returns: RecordMetadata or None if unable to append
169169
"""
170+
if headers is None:
171+
headers = []
170172
if self._closed:
171173
return None
172174

0 commit comments

Comments
 (0)