Кой Kafka клиент беше използван в проекта и как взаимодействахте с него?