minor updates to new kafka api