Metadata-Version: 2.4
Name: algovoi-keystone-kafka
Version: 0.1.3
Summary: Bind Apache Kafka message production to the AlgoVoi keystone -- each produced message gets a content-addressed execution_ref (keystone-only edition, Apache-2.0)
Author-email: AlgoVoi <chopmob@gmail.com>
License: Apache-2.0
Keywords: kafka,streaming,events,keystone,execution_ref,audit,jcs,rfc8785,algovoi
Classifier: License :: OSI Approved :: Apache Software License
Classifier: Programming Language :: Python :: 3
Classifier: Topic :: System :: Distributed Computing
Requires-Python: >=3.10
Description-Content-Type: text/markdown
License-File: LICENSE
License-File: NOTICE
Requires-Dist: algovoi-execution-ref>=0.1.0
Dynamic: license-file

# algovoi-keystone-kafka

[![Keystone Integration](https://img.shields.io/badge/Keystone-integration-7c8aa0)](https://docs.algovoi.co.uk/keystone)

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`.

```python
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.
