В настоящее время я пытаюсь запустить соединитель приемника эластичного поиска в кластере...
Кафка и SQS одинаковы? Я вижу, что оба являются системами очередей сообщений и основаны на событиях
У меня есть «N» количество тем Кафки, где мне нужно принимать сообщения из разных тем и основываясь...
Я написал kafka потребитель и производитель на C, используя библиотеку librdkafka. Версия брокера...
Я хочу использовать Kafka Streams из определенной темы и отправлять данные в WebSocket. У меня есть...
2 моего 3-го кластера Kafka не работает с replica_factor = 2 ץ Меня не волнуют данные, я просто...
Я новичок в apache kafka и настроил kafka-брокера с zookeeper поверх моего самостоятельно...
У нас есть 6 узлов кафки кластера. Из 6 машин 3 имеют Kafka + zookeeper, а остальные 3 имеют только...
У меня проблема с потреблением некоторых файлов json, поскольку они имеют конечные строки в...
У меня есть кластер Kafka с 3-мя серверами и 3-мя брокерами каждый. Я уже в состоянии...
У меня есть приложение Spring Boot, которое пытается прочитать из локальной темы Kafka. Приложение...
Я пытаюсь создать поток как избранный (CSAS), поток создается успешно, но когда я пытался отправить...
Я пытаюсь создать конвейер из kafka и записать его в s3, используя Apache Camel, но проблема, с...
Это мои первые дни в изучении кафки. И я проверяю каждое свойство / концепцию kafka на моей...
Я разработал программу на C ++, которая использует libcppkafka.so.0.2 в качестве библиотеки C ++. Я...
Есть ли у вас какие-либо идеи, почему мое приложение dockerized asp.net не может подключиться к...
Я пытаюсь разобраться в конфигурации flush.size и rotate.interval.ms для разъема S3. Я развернул...
У меня есть приложение Spring с потребителем Kafka, использующее аннотацию @KafkaListerner....
Я начинаю работать в ApacheFlink в Java. Моя цель - использовать тему ApacheKafka в одноминутном...
Я использую kafka_2.12-2.3.1 на Ubuntu 18 с JDK 13. Пока все работает нормально, я заметил, что...
Я буквально не могу ничего сделать с Кафкой: я делаю то, что говорится в инструкциях (https://kafka
USE CASE Я читаю из уже созданной темы Kafka, в которой отдельный кластер создает некоторые ключи и...
Я установил для enable.auto.commit значение true, а для auto.commit.interval.ms - 10000 (т. Е. 10...
Пожалуйста, помогите мне в настройке и запуске сервера Kafka, я мог бы прекрасно запустить...
Прочтите эту статью об упорядочении сообщений в разделе раздела: https://blog.softwaremill