Republish kafka message from one topic to another
Project description
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
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file kafka_republisher-0.2.0.tar.gz.
File metadata
- Download URL: kafka_republisher-0.2.0.tar.gz
- Upload date:
- Size: 4.0 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: poetry/2.2.1 CPython/3.14.0 Linux/6.11.0-1018-azure
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
c9e23cc2564ca41874d981f1f66724f2a8f31942cd0714d1f4ffebfdfbad7964
|
|
| MD5 |
4a62b47dc15ca2820f06db97e0370509
|
|
| BLAKE2b-256 |
83d7f85979b96334ebd6fc530fa6af031933933222514ab1776f94e586bd3ce0
|
File details
Details for the file kafka_republisher-0.2.0-py3-none-any.whl.
File metadata
- Download URL: kafka_republisher-0.2.0-py3-none-any.whl
- Upload date:
- Size: 5.4 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: poetry/2.2.1 CPython/3.14.0 Linux/6.11.0-1018-azure
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
a2ba8982fc2cab90642baaef06c7e1db7c61ee84cb926b69ed3ee4a3ef2f591f
|
|
| MD5 |
f631ad291dc34a295bd20e782ede510d
|
|
| BLAKE2b-256 |
12395ec762ba59611f067af1cc3c508e8dcf8c66cd2ed39edb6d117c211e4c0c
|
