Я знаю, что могу получить всех потребителей, которые назначены для разделов, используя:...

соединение с узлом прекращено во время аутентификации. Это может указывать на то, что...

Сколько потоков zookeeper используется для поддержки кластера Kafka? Как проверить, сколько потоков...

Попытка обернуть голову вокруг семантики сжатой темы kafkas, и возникает конкретный вопрос: что...

Я пытаюсь использовать executeInTransaction для публикации сообщений в kafka в Spring kafka. Но я...

У меня есть кластер Kafka, работающий на локальной машине с настройками по умолчанию вне моей...

У меня есть кластер kafka из 3 брокеров kafka на 3 разных серверах. Предположим, что три сервера....

Я использую PostgreSQL. В моей таблице числовой столбец определен так: "net_weight"...

У меня есть 3 экземпляра зоопарка и 3 экземпляра кафки. Конфигурация в порядке, и я вижу, что они...

Недавно я начал изучать Spring Cloud Stream для Kafka и изо всех сил пытался заставить TestBinder...

Я прочитал много тем о конфигурации и до сих пор не понимаю. когда я делаю: ../kafka_2.11-1.1

Я использую пружинную кафку со следующими конфигурациями: props.put(ConsumerConfig

При попытке использовать kafkacat с концентратором сообщений я использовал следующее: kafkacat -X...

Я установил Apache Kafka с Java 8 и Oracle JDK. Однако моя компания планирует перейти на OpenJDK...

Я новичок в kafka, у меня есть следующий пример кода: KafkaConsumer<String,String> kc = new...

Я хочу получить список групп потребителей Kafka с python, но не смог. Я использую zookeeper python...

У меня есть приложение Spring Cloud Stream, использующее Spring Boot 2.0.3.RELEASE и библиотеки...

Как отправить запись Consumer в объект Storm Spout в одной строке кода? У меня есть два экземпляра,...

Я хочу создать одновременную @KafkaListener, которая может обрабатывать несколько тем, каждая с...

Я хочу настроить Kafka Connect для записи максимально возможного количества записей в HDFS (мне...

У меня есть следующая конфигурация: Одна тема кафки с 2 разделами Один экземпляр Zookeeper Один...

Я хотел бы добавить содержимое архива Apache Kafka .tgz в дистрибутив моего проекта Maven. Я не...

Я настоящий новичок в Шторме. У меня есть требование, которое очень похоже на следующее: Допустим,...

Я новичок в очередях сообщений в целом, и в данный момент я работаю с apache Kafka. У меня есть...

Мы работаем над созданием приложения Kafka-connect, используя исходный соединитель JDBC в режиме...