collector-to-emulator

convert kafka-collector jsonl output into kafka-emulator scenario yaml.

Installation

pip install collector_to_emulator

Usage

$ collector-to-emulator -h
usage: collector-to-emulator [-h] [-v] [-i PATH] [-t DIR] [-n NAME] [-s PATH]
                             [-g MS] [-c MS] [-r MS]
                             [JSONL]

convert kafka-collector output into kafka-emulator config

positional arguments:
  JSONL                 JSONL file (if stdin is a TTY and -i omitted)

options:
  -h, --help            show this help message and exit
  -v, --version         show program's version number and exit
  -i, --input PATH      JSONL file (ignored when stdin is piped)
  -t, --template-dir DIR
                        template output directory (default: templates/)
  -n, --name NAME       scenario name in generated YAML (default: Unnamed)
  -s, --scenario PATH   scenario YAML path when stdout is a TTY (default:
                        scenario.yaml)
  -g, --sleep-gap MS    emit a sleep step when the gap between timestamps
                        exceeds this many milliseconds (default: 500)
  -c, --sleep-cap MS    maximum sleep duration in milliseconds when inserting
                        a sleep step (default: 5000)
  -r, --round MS        round each sleep duration to the nearest multiple of
                        this many milliseconds (default: 1, no rounding)

Badges

GitHub GitHub last commit GitHub tag (latest by date) GitHub issues GitHub closed issues GitHub pull requests GitHub closed pull requests GitHub top language GitHub language count GitHub repo size GitHub code size in bytes

Workflow

Release GitHub release (latest by date) GitHub all releases GitHub Release Date

Quality-Qlty

Quality-Sonar Sonar Violations (short format) Sonar Violations (long format)

visitors

Release files for collector_to_emulator 1.0.0

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for collector_to_emulator 1.0.0
File	Size	Uploaded
collector_to_emulator-1.0.0.tar.gz	10.1 kB	Apr 14, 2026	Details

Built distribution (wheel)

Table of built distributions (wheels) for collector_to_emulator 1.0.0
File	Interpreter	ABI	Platform	Reset
collector_to_emulator-1.0.0-py3-none-any.whl 11.3 kB Apr 14, 2026	Python 3	none	any	Details

Total release size: 21.4 kB

Release files / collector_to_emulator-1.0.0.tar.gz

Download URL	collector_to_emulator-1.0.0.tar.gz
Size	10.1 kB
Tags	Source
SHA-256 checksum How to use checksums	`984b46737b48608ec40f6c5c1fbd92df5c130af394565d797f03c13109ff64ab`
BLAKE2b-256 checksum How to use checksums	`a9b88832333d91cb858b12697f171a8a844af5176d6a37f97c8baa4780f228ad`
Upload date	Apr 14, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`poetry/2.3.4 CPython/3.14.3 Linux/6.17.0-1010-azure`

Release files / collector_to_emulator-1.0.0-py3-none-any.whl

Download URL	collector_to_emulator-1.0.0-py3-none-any.whl
Size	11.3 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`456a0ed4245432575b115c2f13a05800f49e62c982c1103b19f8907c80c8917e`
BLAKE2b-256 checksum How to use checksums	`305a2a716bde643416607f11d548ccbd5d3b2cec2d46dd0ea9bfdd19959bb5fc`
Upload date	Apr 14, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`poetry/2.3.4 CPython/3.14.3 Linux/6.17.0-1010-azure`