Tags: gojek/kat
Tags
Partition level batching for partition reassignment operation (#18) * changes to admin and katclient interface to accept partitionBatchSize * added test for partitionBatchSize support * added partitionBatching implementation * change file names for partitions-reassignment * move from folder to plain files for easier use. * set partition batch to 10 as default. add more info logs. * updated description for partition batch size and topic batch size params * Updated README.md about the partition-batch-size
Allow Graceful shutdown after a SIGINT (#17) * Add resume flag to resume topics to be used for reassigning * added a go routine to listen for SIGTERM * extracted out signal handling responsibility to signalhandler.go * add graceful pause test for partition reassignment * changed signal to pause from SIGTERM to SIGINT * made signalhandler use the same wg instead of copying * Improved doc around resume flag. Improved log for Interrupt notification Made test stricter. * added .sh suffix to the command as it wasn't able to detect any executable in mac. Linux doesn't require suffix but mac does. * executor command to start in a different process group to not inherit the interrupt signal. * log resume from topic statement * added gotchas about graceful shutdown and resume in README
PreviousNext