|0.1.9||Jun 28, 2022|
|0.1.8||Jun 28, 2022|
|0.1.7||May 8, 2022|
|0.1.6||Apr 29, 2022|
|0.1.1||Mar 27, 2022|
#335 in Database interfaces
200 downloads per month
We are using:
cargo 1.60.0 (d1fd9fe 2022-03-01)
With Docker Compose - Nerdctl Compose
- You need to have docker installation locally. With containerd backend, if you want to bring single node Kafka replacement use:
nerdctl compose up
If you want to bring Confluent Kafka single node. You can:
nerdctl compose -f docker-compose.kafkasn.yml
If you want to bring full blown Confluent Kafka cluster. Use:
nerdctl compose -f docker-compose.kafkacluster.yml
nerdctl command is interchangeable with
- You need to have K8S installation locally.
cd k8s && kubectl apply -f . && kubectl port-forward svc/redpanda 9092:9092
- Now you can run the producers in Python.
virtualenv venv source venv/bin/activate which pip3 # check that it is pointing to venv pip3 install aiokafka -U python examples/producer.py
- Now you can spawn the double agent example (without durability).
RUST_LOG="info,rdkafka::client=warn" RUST_BACKTRACE=full cargo run --example double-agent
Environment variables passed above is optional, but suggested for development.