class_docstr: KafkaIOLayerHelper
code: def check(self, images, predictions):
      import tensorflow_io.kafka as kafka_io
  
      f = kafka_io.KafkaDataset(
          topics=[self._topic], group="test", eof=True
      )
      lines = list(f)
      assert np.all(lines == predictions)
  
      assert len(lines) == len(images)
  
file_path: io/tests/test_io_layer.py
imports: import os
  import sys
  import time
  import tempfile
  import pytest
  import numpy
  import tensorflow
  import tensorflow_io
label_desc: Use image node_id 2 for calling the KafkaIOLayerHelper obj's underlying member method code with example usage: obj.check(images, predictions) without return types