4.3.7. Kafka操作