code: def test_kafka_group_io_dataset_primary_cg_new_topic():
      """Test the functionality of the KafkaGroupIODataset when the existing
      consumer group reads data from a new topic.
      """
      dataset = tfio.experimental.streaming.KafkaGroupIODataset(
          topics=["key-test"],
          group_id="cgtestprimary",
          servers="localhost:9092",
          configuration=[
              "session.timeout.ms=7000",
              "max.poll.interval.ms=8000",
              "auto.offset.reset=earliest",
          ],
      )
      assert np.all(
          sorted(k.numpy() for (k, _) in dataset)
          == sorted(("D" + str(i)).encode() for i in range(10))
      )
  
imports: import sys
  import time
  import pytest
  import numpy
  import threading
  import tensorflow
  import tensorflow_io
label_desc: Use image node_id 9 for calling a global function with example usage: test_kafka_group_io_dataset_primary_cg_new_topic() without return types