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.