Я слежу за документацией друидов, но при запуске команды curl -XPOST -H'Content-Type:...
Я использовал исходный соединитель JDBC для передачи данных из тем оракула в кафку.У меня есть темы...
Я планирую отправлять журналы в наш сотрудничающий кластер эластичного поиска. Я использую td-agent...
У меня проблема с JDBC-стоком с этой аркой. postgres1 ---> kafka ---> postgres2 производитель...
Не удается разрешить символ для Foreach import java.util._ import org.apache.kafka.clients.consumer
У меня есть ZooKeeper с узлами, которые используют схему ACL "дайджест": https://zookeeper.apache
Мы используем Confluent's Kafka S3 Connector , версия 5.2.1.Работая с одним узлом в настройке...
Spring Boot: 2.0.3.RELEASE org.apache.kafka.kafka-streams: 1.0.0 org.apache.kafka.kafka-клиентов: 1
Я пытаюсь запустить Кафку в докере.Он работает с открытым текстом, но не работает с SSL. Я выполнил...
У меня есть приложение kafka-streams, в котором полезная нагрузка проходит через несколько тем,...
Я использую несколько Java-приложений Kafka, некоторые из которых являются потоками Kafka, другие...
Я создал производителя akka kafka, мне нужно подключить его к брокеру kafka с использованием...
Я пытаюсь использовать возрастающую загрузку, чтобы создать сообщение для темы об обновлении...
Я пытаюсь написать соединитель Kafka для получения данных из Facebook. Проблемы, Как получить...
Это моя потребительская конфигурация: @Configuration @EnableKafka public class KafkaConfiguration {...
Запуск этого приложения в многоузловом кластере kafka и подключение к сети Docker с использованием...
Мы работаем с 5-узловым кластером Flink (1.6.3) над kubernetes с источником раздела Kafka из 5...
--- version: '2' services: zookeeper-1: image: confluentinc/cp-zookeeper:latest...
Я пытаюсь запустить zookeeper с помощью kafka_2.12_2.2.0. При нормальном запуске все работает...
Я новый человек на Apache Kafka.Когда я прохожу инструкции по быстрому запуску через http://kafka
Я пытаюсь интегрировать kafka с моим приложением Spring boot (v2.0.6.RELEASE), используя...
У меня проблемы с настройкой входа в систему с помощью Akka. В моем STDOUT это не скрывает их...
У меня есть в докере зоокейпер, кафка, телеграф, influenxdb, postgres и другие version: '2
Я хочу интегрировать сервер Wazuh с HELK , но я не могу этого сделать, и logstash не может получить...
Я использовал kafka продуцента, версия которого 0.8.2.1, для записи брокеру kafka, версия 1.0.1...