code: def test_kafka_group_io_dataset_invalid_stream_timeout():
      """Test the functionality of the KafkaGroupIODataset when the
      consumer is configured to have an invalid stream_timeout value which is
      less than the message_timeout value.
      NOTE: The default value for message_timeout=5000
      """
  
      STREAM_TIMEOUT = -20
      try:
          tfio.experimental.streaming.KafkaGroupIODataset(
              topics=["key-partition-test", "key-test"],
              group_id="cgteststreaminvalid",
              servers="localhost:9092",
              stream_timeout=STREAM_TIMEOUT,
              configuration=[
                  "session.timeout.ms=7000",
                  "max.poll.interval.ms=8000",
              ],
          )
      except ValueError as e:
          assert str(
              e
          ) == "Invalid stream_timeout value: {} ,set it to -1 to block indefinitely.".format(
              STREAM_TIMEOUT
          )
  
imports: import sys
  import time
  import pytest
  import numpy
  import threading
  import tensorflow
  import tensorflow_io
label_desc: Use image node_id 15 for calling a global function with example usage: test_kafka_group_io_dataset_invalid_stream_timeout() without return types