Merge "kafka: Implement ack handling"