test_producer.py 文件源码

def _get_record_metadata(self):
        return ConsumerRecord(
            topic=TOPIC_STATES,
            partition=0,
            offset=42,
            timestamp=1467649216540,
            timestamp_type=0,
            key=b'NY',
            value=b'foo',
            checksum=binascii.crc32(b'foo'),
            serialized_key_size=b'NY',
            serialized_value_size=b'foo')