Как работи репликацията в Kafka, какво се случва, когато брокерът се провали, и как да се гарантира, че записът е репликиран?