Используя kafka-console-producer Я могу отправлять сообщения в тему acl, используя пользователя...
Я работаю с Kafka Connect (используя реализацию Confluent) и наблюдаю странное поведение. Я...
В настоящее время я работаю над проектом kafka java. Я новичок в этом, и мне трудно понять...
Я использую фреймворк для микронавтов. У меня есть некоторый оставшийся (потоковый) API, и мне...
Я планирую обновить клиент kafka с 0.8.2.1 до 2.1.1. Нужна помощь в том, как это сделать? Мой...
Я знаю, что уже есть некоторые темы, касающиеся вышеупомянутой ошибки, но я все еще имею ее,...
Я пытаюсь подключиться к контейнеру док-станции kafka из контейнера док-станции logstash, но всегда...
У нас есть микросервисная архитектура в нашем проекте. Существует микросервис, в котором...
Я пытаюсь найти некоторую информацию о производительности и (или) преимуществах использования двух...
У меня есть следующий файл docker-compose: version: '3.1' services: postgres_db: image:...
Это таблица: val res: Table = tenv.sqlQuery( """ |select event.ID,event.locationID,...
(отправка от имени клиента Snowflake ...) ......................... Я пытаюсь подключить Kafka к...
По состоянию на ОКТЯБРЬ 2019 с Kafka v2.3.0 и Zookeeper v3.5.5 СЦЕНАРИЙ: Рассмотрим приведенный...
Я новичок в kafka и quarkus, я хочу отправить сообщение в тему kafka после обработки запроса...
Я делаю POC из Confluent Kafka Connect версии 5.2.3. Мы пытаемся скопировать сообщение темы из...
Мне удалось получить данные формы от начала до конца определенной темы Кафки, используя параметр...
Сейчас я выполняю нагрузочный тест на разъеме Debezium postgres, чтобы узнать, может ли он...
Я реализовал потребителя Kafka, теперь у меня есть сценарий. Чтение данных из потока Kafka 2.2.5....
Я использую Confluent JDBC Sink Connector для записи всех изменений из темы Kafka в базу данных....
Kafka Одноранговый узел SSL не аутентифицирован, вместо него возвращается ошибка ANONYMOUS при...
Вот метод переопределения для обработки записей: @Override public void...
У меня есть кластер Kafka с 5 брокерами, и минимальный ISR равен 2. Теперь один из...
У меня есть служба Kafka с диском 1000 ГБ и этот рабочий параметр: log.retention.bytes=350000000000...
У меня есть экземпляр Kafka, работающий на другой машине в моей локальной сети, которую я пытаюсь...
Я использую Debezium MongoDB Connector для прослушивания определенной коллекции MongoDB, чтобы...