Я новичок в кафке, поэтому извиняюсь, если что-то упустил. Я пытаюсь использовать сообщения из существующей темы. Я получил код примера Spring Integration Basic Kafka из this ссылка. Мой код в настоящее время выглядит так:...

В logstash я пытаюсь отправить данные в kafka, а также в ES. В ES данные отправляются в том же формате, что и rubydebug (в основном данные json после применения фильтров и добавления нового поля). Я хочу отправить те же данные в кафку. Но logstash...

У меня есть файл журнала доступа apache, и я хочу хранить счетчики доступа (всего/ежедневно/ежечасно) каждой страницы в таблице cassandra. Я пытаюсь сделать это, используя kafka для подключения к потоку из файла журнала в тему kafka. Могу ли я...

Я хочу интегрировать сервер Wazuh с HELK , но я не могу этого сделать, и logstash не может получить оповещение Wazuh из kafka или отправки предупреждений Wazuh в Elasticsearch. Я создаю тему kafka с именем «wazuh-alerts» и устанавливаю свою...

Свойства моей раковины: { "name": "jdbc-oracle", "config": { "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector", "tasks.max": "1", "topics": "orders", "connection.url": "jdbc:oracle:thin:@10.1.2.3:1071/orac",...

Я использую zookeeper версии 3.5.8. когда я удаляю тему с помощью команды удаления темы zookeeper, она выдает ошибку:

Экспериментировал с переключением топологии Storm 1.0.6 на Heron. Сделав маленький шаг, удалив все, кроме носика Kafka, чтобы посмотреть, как идут дела. Имейте основной метод следующим образом (измененный из исходной версии Flux): import...