1 2 3
from kafka.record.memory_records import MemoryRecords, MemoryRecordsBuilder __all__ = ["MemoryRecords", "MemoryRecordsBuilder"]