def create_table_output_kafka()

in PythonKafkaSink/main.py [0:0]

• 2 lines of code
• 1 McCabe index (conditional complexity)

def create_table_output_kafka(table_name, stream_name, broker):
    return """ CREATE TABLE {0} (