Каким образом осуществляется репликация данных в Apache Kafka?