There's also a Reddit conversation going on a similar topic https://www.reddit.com/r/apachekafka/comments/dvodn9/swap_ap...