Kaip išplėsti pranešimų apdorojimą Kafka vartotojo pusėje; kas yra partition ir kaip pranešimai paskirstomi tarp partition'ų?