code: def fixture_kafka_avro():
      """fixture_kafka_avro"""
  
      schema = (
          '{"type":"record","name":"myrecord","fields":['
          '{"name":"f1","type":"string"},'
          '{"name":"f2","type":"long"},'
          '{"name":"f3","type":["null","string"],"default":null}'
          "]}"
      )
  
      args = "avro-test"
  
      def func(q):
          v = tfio.IODataset.from_kafka(q)
          # remove key
          v = v.map(lambda e: e.message)
          # remove kafka framing
          v = v.map(lambda e: tf.strings.substr(e, 5, -1))
          # deserialize avro
          v = v.map(
              lambda e: tfio.experimental.serialization.decode_avro(
                  e, schema=schema
              )
          )
          # map to value
          v = v.map(lambda e: e["f1"])
          return v
  
      expected = [b"value1", b"value2", b"value3"]
  
      return args, func, expected
  
imports: import os
  import sys
  import time
  import shutil
  import tempfile
  import numpy
  import pytest
  import tensorflow
  import tensorflow_io
label_desc: Use image node_id 28 for calling a global function with example usage: fixture_kafka_avro() and returns: args,  func,  expected, v