code: def test__unpack_message_set(fetcher):
      fetcher.config["check_crcs"] = False
      tp = TopicPartition("foo", 0)
      messages = [
          (None, b"a", None),
          (None, b"b", None),
          (None, b"c", None),
      ]
      memory_records = MemoryRecords(_build_record_batch(messages))
      records = list(fetcher._unpack_message_set(tp, memory_records))
      assert len(records) == 3
      assert all(map(lambda x: isinstance(x, ConsumerRecord), records))
      assert records[0].value == b"a"
      assert records[1].value == b"b"
      assert records[2].value == b"c"
      assert records[0].offset == 0
      assert records[1].offset == 1
      assert records[2].offset == 2
  
imports: from __future__ import absolute_import
  import pytest
  from collections import OrderedDict
  import itertools
  import time
  from kafka.client_async import KafkaClient
  from kafka.consumer.fetcher import CompletedFetch, ConsumerRecord, Fetcher, NoOffsetForPartitionError
  from kafka.consumer.subscription_state import SubscriptionState
  from kafka.future import Future
  from kafka.metrics import Metrics
  from kafka.protocol.fetch import FetchRequest, FetchResponse
  from kafka.protocol.offset import OffsetResponse
  from kafka.errors import StaleMetadata, LeaderNotAvailableError, NotLeaderForPartitionError, UnknownTopicOrPartitionError, OffsetOutOfRangeError
  from kafka.record.memory_records import MemoryRecordsBuilder, MemoryRecords
  from kafka.structs import OffsetAndMetadata, TopicPartition
label_desc: Use image node_id 15 for calling a global function with example usage: test__unpack_message_set(fetcher) without return types