Repository navigation
Releases
Releases · gnocent/kcg
kcg v0.1.0
First public version.
read: one row per partition, one column per group, with log start and end; most advanced group, active groups and
offsets below the log start marked.align --from oldest|newest|earliest|latest|<offset>|<group> --to <group>|all.delete(groups × topics × partitions) andclean(one reference group kept per topic, refusal with the
conflicting partitions when ambiguous,--keepto decide).- Dry run by default,
--executeto write,--forceto move offsets backward, groups with active members refused
(classic and KIP-848), CSV backup before every write andrestore. - Connection as with the Kafka tools:
--bootstrap-server,--command-config(SASL PLAIN/SCRAM, TLS in PEM or PKCS12). - Tested on Kafka 3.9 and 4.4.
Install: download the archive for your system below (checksums in SHA256SUMS), or go install github.com/gnocent/kcg@v0.1.0.