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
  • ProtobufProtocol
    • ProtobufProtocol.j_object_type
    • ProtobufProtocol.raw()
    • ProtobufProtocol.serdes()
  • SEEK_TO_BEGINNING
  • SEEK_TO_END
  • TableType
    • TableType.append()
    • TableType.blink()
    • TableType.j_object_type
    • TableType.ring()
    • TableType.stream()
  • avro_spec()
  • consume()
  • consume_to_partitioned_table()
  • json_spec()
  • object_processor_spec()
  • protobuf_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.

topics(kafka_config)

Returns a list of topic names available from Kafka.

Parameters:

kafka_config (Dict) – configuration for the associated Kafka consumer. The content is used to call the constructor of org.apache.kafka.clients.Admin; pass any Admin specific desired configuration here

Return type:

List[str]

Returns:

a list of topic names

Raises:

DHError –