algovoi-keystone-kafka 0.1.3

Bind Apache Kafka message production to the AlgoVoi keystone -- each produced message gets a content-addressed execution_ref (keystone-only edition, Apache-2.0)

algovoi-keystone-kafka

Bind Apache Kafka message production to the AlgoVoi keystone -- each produced message gets a content-addressed execution_ref. Open, keystone-only edition, Apache-2.0. Byte-compatible with algovoi-execution-ref.

from algovoi_keystone_kafka import keystone_producer

kp = keystone_producer(producer, decision_ref="sha256:...")   # wraps kafka-python/confluent/aiokafka
kp.send("orders", b"payload")
kp.execution_ref   # binds that produced message to the keystone decision

Or standalone: kafka_execution_ref(decision_ref=..., topic="orders", outcome="COMMITTED", executed_at_ms=...). No hard Kafka dependency -- wraps any producer with send/produce.

A failed operation is recorded with outcome FAILED; tamper_detected(...) recomputes any binding offline.

Keystone-only edition

The open edition binds and verifies each operation. The signed, hash-linked chain of operations (PQC + CCC ingest) is the commercial tier.

License

Apache-2.0. Copyright AlgoVoi.