logging changes and key based kafka partitioning