Я использовал коннектор Confluent ElasticSink для передачи sh данных из kafka topi c в поиск Elasti c. Все это было сделано на моей локальной машине, и я выполнил локальный запуск слияния, а затем загрузил существующий разъем Elasti c для мойки. Я мог видеть, как данные передаются в Elasti c API.
Однако в моей компании у нас уже есть среда Ambari, которую мы используем для запуска брокеров Kafka. Есть ли правильный способ использовать коннектор раковины elasti c в Ambari? Как мне go справиться с этим?
Можно ли добавить реализацию Elasti c Sink Connector из Confluent к Apache kafka libs и использовать ее оттуда?