Memoize database check
Add better parallelization hints
bump kafka library versions add keys to producer to make sure writes are distributed across kafka partitions