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

У меня есть класс User, и я разделяю его как avro (используя Confluent avro serializer и реестр...

Я хочу реализовать сжатие для кафки сообщений. Для этого должен быть установлен тип сжатия. В каком...

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

У меня есть один экземпляр клиента kafka, который потребляет 200 разделов, теперь я хочу, чтобы он...

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

У меня проблемы с чтением из Kafka в наших одно-узловых средах разработки Мы работаем с одноузловым...

Мы подписываемся на производителя кафки с нашим потребителем, и в нашей реализации мы застряли...

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

Я пытаюсь читать сообщения Кафки, используя потребителя Кафки в jmeter, используя сэмплер jsr223. я...

Я работаю над разъемом MQTT kafka. Сообщения Исходя из MQTT Publisher, соединитель будет подписан...

Я пытаюсь присоединиться к следующему потоку Field | Type ---------------------------------------...

Я новичок в докерах. Я должен создать контейнер Кафки в котором будет потребительский контейнер,...

Я настроил kafka (1.0) с включенным SSL и добавил свойство слушателей как...

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

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

Я пытаюсь собрать kafka-connect-hdfs, следуя этому FAQ. При попытке скомпилировать схему-реестр я...

у меня есть схема { "type" : "record", "name" : "test",...

В случае интеграционного тестирования я отправляю запись в Kafka и хотел бы знать, когда она будет...

У меня развернута кафка коннект эластичного поиска. Соединение распределенное работает на слиянии 3

Можно ли запустить полную платформу Confluent в Windows? Если нет, то какой способ запуска...

Я новичок в очереди сообщений. Назовите его RabbitMQ, Service Bus, Kafka и т. Д. Я пытаюсь найти...

Я пытаюсь подключить kafka в Docker из приложения NodeJs, используя kafka-node . Приложение...

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

Я читаю потоковые данные из темы Кафки, и я хочу сохранить некоторые ее части в кадре данных pandas