deephaven.stream.kafka# cdc CDCSpec CDCSpec.j_object_type cdc_long_spec() cdc_short_spec() consume() consume_raw() consumer ALL_PARTITIONS_DONT_SEEK ALL_PARTITIONS_SEEK_TO_BEGINNING ALL_PARTITIONS_SEEK_TO_END DONT_SEEK KeyValueSpec KeyValueSpec.j_object_type SEEK_TO_BEGINNING SEEK_TO_END TableType TableType.append() TableType.j_object_type TableType.ring() TableType.stream() avro_spec() consume() consume_to_partitioned_table() json_spec() simple_spec() producer KeyValueSpec KeyValueSpec.j_object_type avro_spec() json_spec() produce() simple_spec() The kafka module provides the utilities to both consume and produce Kakfa streams.