From e53d6d56e2da740b1245a8e09a1d0c462afed251 Mon Sep 17 00:00:00 2001 From: Devin Smith Date: Mon, 24 Jul 2023 08:05:32 -0700 Subject: [PATCH] Fix kafka consume value_spec docs --- py/server/deephaven/stream/kafka/consumer.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/py/server/deephaven/stream/kafka/consumer.py b/py/server/deephaven/stream/kafka/consumer.py index a7a6b6eab56..0842bc71382 100644 --- a/py/server/deephaven/stream/kafka/consumer.py +++ b/py/server/deephaven/stream/kafka/consumer.py @@ -160,7 +160,7 @@ def consume( It can be the result of calling one of the functions: simple_spec(),avro_spec() or json_spec() in this module, or the predefined KeyValueSpec.IGNORE or KeyValueSpec.FROM_PROPERTIES. The default is None which works the same as KeyValueSpec.FROM_PROPERTIES, in which case, the kafka_config param should include values - for dictionary keys 'deephaven.key.column.name' and 'deephaven.key.column.type', for the single resulting + for dictionary keys 'deephaven.value.column.name' and 'deephaven.value.column.type', for the single resulting column name and type table_type (TableType): a TableType, default is TableType.blink() @@ -205,7 +205,7 @@ def consume_to_partitioned_table( It can be the result of calling one of the functions: simple_spec(),avro_spec() or json_spec() in this module, or the predefined KeyValueSpec.IGNORE or KeyValueSpec.FROM_PROPERTIES. The default is None which works the same as KeyValueSpec.FROM_PROPERTIES, in which case, the kafka_config param should include values - for dictionary keys 'deephaven.key.column.name' and 'deephaven.key.column.type', for the single resulting + for dictionary keys 'deephaven.value.column.name' and 'deephaven.value.column.type', for the single resulting column name and type table_type (TableType): a TableType, specifying the type of the expected result's constituent tables, default is TableType.blink()