def METHOD_NAME(self):
    t = table_helper()
    cleanup = pk.produce(
        t,
        {'bootstrap.servers': 'redpanda:29092'},
        'orders',
        key_spec=KeyValueSpec.IGNORE,
        value_spec=pk.json_spec(
            ['Symbol', 'Price'],
            mapping={'Symbol': 'jSymbol', 'Price': 'jPrice'},
            timestamp_field='jTs'
        ),
        last_by_key_columns=False
    )
    self.assertIsNotNone(cleanup)
    cleanup()