kafka-republisher
Republish kafka message from one topic to another, optionally with delay
Example environments:
BOOTSTRAP_SERVERS: kafka:9092
FROM_TOPIC: topicA
TO_TOPIC: topicB
SLEEP_TIME: 30
GROUP_ID: delayer
docker build
cd docker
docker build -t siakhooi/kafka-republisher:latest .
docker login -p xxxtoken
docker push siakhooi/kafka-republisher:latest
Deliverables
Installation
pip install kafka_republisher
Usage
$ kafka-republisher -h
usage: kafka-republisher [-h] [-v]
Kafka Mock Messages Sender
options:
-h, --help show this help message and exit
-v, --version show program's version number and exit
Links
- https://pypi.org/project/kafka_republisher/
- https://github.com/siakhooi/kafka-republisher
- https://sonarcloud.io/project/overview?id=siakhooi_kafka-republisher
- https://qlty.sh/gh/siakhooi/projects/kafka-republisher
Badges
1 maintainer
Release files for kafka_republisher 1.0.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| kafka_republisher-1.0.0.tar.gz | 5.1 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| kafka_republisher-1.0.0-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 12.4 kB
Release files / kafka_republisher-1.0.0.tar.gz
| Download URL | kafka_republisher-1.0.0.tar.gz |
|---|---|
| Size | 5.1 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
c5c5de441553ba9d77fd07d8fb03dd1cc47d93af127feb3dec684f43e095a6ae
|
|
BLAKE2b-256 checksum How to use checksums |
3cd9377f8a7decc52d8efa0870bcadb13ff1df93f868ea35fcb86125e1c84084
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
poetry/2.3.3 CPython/3.14.3 Linux/6.17.0-1008-azure
|
Release files / kafka_republisher-1.0.0-py3-none-any.whl
| Download URL | kafka_republisher-1.0.0-py3-none-any.whl |
|---|---|
| Size | 7.3 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
38d1f5203b7194a8af37ab5c89f5bbc7460b28c6934bfe6607bff215366dc47d
|
|
BLAKE2b-256 checksum How to use checksums |
f66235447e2a500df527d24f4aa11fb424c6abb66d1b687a38c6f4a0ddf20177
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
poetry/2.3.3 CPython/3.14.3 Linux/6.17.0-1008-azure
|
