Я создал тему вручную test с помощью этой команды: bin/kafka-topics.sh --create --zookeeper...

Я сделал прямой поток с pyspark kafka.Но я не мог установить значение fromOffset в нем.Это дает мне...

Мне интересно, можно ли использовать Apache Kafka для отказоустойчивой среды с реляционными базами...

Я пытаюсь сделать маленький PoC с Кафкой.Однако при создании потребителя в Java этот потребитель не...

Я недавно включил двухстороннюю аутентификацию на своем кластере Kafka. Я пытаюсь использовать...

Я новичок в Golang и Kafa, так что это может показаться глупым вопросом. После того, как мой...

I am sending `List<Object>` from Kafka Producer to a topic. A consumer which listens to the...

Поэтому, когда наше приложение Scales-Up / Scales-Down перегруппировывается в Kafka Consumer Group....

Просматривая код потребителя Camel Kafka, можно увидеть, что в KafkaFetchRecords есть следующий...

Потребитель должен проверять сообщения с интервалом в 10 минут, это ответное сообщение должно...

Я использую Python Language.У меня есть CSV-файл, мне нужно конвертировать в JSON и отправить в...

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

У меня есть 2 разных сообщения-экземпляра приложения, использующих тему, оба приложения имеют...

Привет, я пытаюсь переместить данные в формате csv из kafka в hdfs, используя соединитель приемника...

У меня есть KafkaConsumer, который вызывает метод подписки для определенной темы (например, topic1)

Получение следующей ошибки (Kafka 2.1.0): 2018-12-03 21: 22: 37.873 ОШИБКА 37645 ---...

Я использую KafkaConsumer со следующими настройками enable.auto.commit = true auto.commit.interval

Попытка использовать confluent_kafka.AvroConsumer для получения сообщений с заданной отметкой...

В моих темах 115 разделов и около 130 потребителей.Я ожидаю, что 115 потребителей в активном...

Исходя из моего понимания Производитель: При первом вызове локальный кеш реестра схемы пуст. Затем...

У меня проблемы с использованием данного смещения с использованием python, в Java я реализовал...

Я реализовал расширенную функцию приемника, которая выполняет некоторые сетевые вызовы для каждого...

В моем приложении я настроил kafka для работы с TLS, поэтому у меня есть несколько потребителей,...

Мы бы хотели перечислить все темы Kafka с помощью spring-kafka, чтобы получить результаты,...

У меня есть тема Кафки с N разделами.Ключ записи - это cookie.Записи распределяются по разделам по...