add  kafka replication test