add test cases after the kafka 11 upgrade changes