kafka_node changes adding pause/resume