Skip to content

Commit 1df2f35

Browse files
committed
Fix a bug with using a wrapper object
1 parent 57cebcf commit 1df2f35

File tree

1 file changed

+1
-1
lines changed
  • py/server/deephaven/stream/kafka

1 file changed

+1
-1
lines changed

py/server/deephaven/stream/kafka/cdc.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ def consume_raw(
9898
kafka_config = j_properties(kafka_config)
9999
if table_type is None:
100100
table_type = TableType.blink()
101-
return Table(j_table=_JCdcTools.consumeRawToTable(kafka_config, cdc_spec.j_object, partitions, table_type))
101+
return Table(j_table=_JCdcTools.consumeRawToTable(kafka_config, cdc_spec.j_object, partitions, table_type.j_object))
102102
except Exception as e:
103103
raise DHError(e, "failed to consume a raw CDC stream.") from e
104104

0 commit comments

Comments
 (0)