Я достаточно много искал по этому вопросу, но, похоже, нет хорошего руководства по этому вопросу....

"log.retention.bytes" - это параметр, который мы используем для хранения журналов сообщений тем, и...

Я работаю над загрузочным приложением Spring с spring kafka, которое прослушивает отдельную тему...

Я очень новичок в кафке.Мы пишем потребителю в нашем текущем приложении, которое использует тему и...

Я пытаюсь реализовать "Адаптер Pulsar для Apache Kafka" через Java, и я следую тот же документ с...

Я пытаюсь заполнить тему kafka некоторыми тестовыми данными, такими как: public static void...

Я рассмотрел пример слияния потока потока кафки и обнаружения аномалий. В этом примере результат...

Я пытаюсь получить данные из Kafka с помощью коннектора debezium MongoDB, но получаю сообщение об...

Я пытаюсь прочитать данные JSON из Kafka, используя следующий код: @source(type = 'kafka'...

У меня исключение kafka при создании сообщения с ruby-kafka. Такое бывает иногда. Кафка 1.1.0,...

У меня есть тема Kafka, содержащая сообщения с сериализованным ключом Avro и сериализованным...

В моем понимании, когда я хочу отправить фильм (4 ГБ) брокеру Kafka, один производитель отправит...

Есть ли список файлов журналов / приложений, которые я могу настроить для включения в kafka /...

У меня есть вариант использования, когда мне нужно скопировать данные из одной темы в другую тему в...

Intellij и Eclipse не разрешают зависимости для плагинов (maven-clean-plugin, maven-install-plugin,...

Я хочу использовать Кафку для JUnit , поэтому я добавил эту зависимость: <dependency>...

У меня есть потребитель kakfa, для которого enable.auto.commit имеет значение false . Всякий раз,...

Я установил конфлюэнтную Kafka на двух разных хостах и ​​пытаюсь заставить конфлюентный репликатор...

Я хочу использовать Spark Structured Streaming для чтения с защищенной кафки. Это означает, что мне...

Производитель A пишет сообщение брокеру A (раздел 1), а производитель B пишет то же сообщение...

Кафка раньше отлично работала на моем собственном компьютере.сейчас я работаю на другом компьютере,...

В задании Google Dataflow используется библиотека KafkaIO от Apache Beam с AvroIO и Windowed....

Я создал пример топологии со Storm, используя Кафку в качестве источника. Вот проблема, решение...

Я пытаюсь реализовать архитектуру RPC, используя Кафку в качестве посредника сообщений. Решение об...

Я установил confluent-oss-5.0.0 на виртуальной машине Azure и открыл доступ ко всем необходимым...