Kafka

experimentalnetwork

Enterprise Kafka event stream operations

pip install chp-adapter-kafka

Auto-discovered through the chp.adapters entry point — no host config needed.

Capabilities

What this adapter exposes.

consumev0.1.0

Consume messages from a Kafka topic. Message values returned to caller but never in evidence.

chp.adapters.kafka.consume

list_topicsv0.1.0

List available Kafka topics.

chp.adapters.kafka.list_topics

publishv0.1.0

Publish a single message to a Kafka topic. Value never in evidence.

chp.adapters.kafka.publish

publish_batchv0.1.0

Publish multiple messages to a topic. Message values never in evidence.

chp.adapters.kafka.publish_batch

topic_metadatav0.1.0

Fetch partition and message-count metadata for a topic.

chp.adapters.kafka.topic_metadata