deephaven.stream.kafkaΒΆ cdc consumer producer The kafka module provides the utilities to both consume and produce Kakfa streams.