Merge "authorization check for more Kafka operations"