Я пытаюсь создать приложение Kafka Streams, которое обрабатывает записи Avro, но я получаю...
Мы настраиваем мониторинг для GC для Kafka, на котором запущен Jolokia JMX агент.Мы используем...
Наша система kafka вышла из строя из-за отсутствия свободного места на диске.Потребителями являются...
Я только начал работать с Kafka 2.1.0 сегодня и изучаю API производителя.У меня есть следующий код:...
В библиотеке Confluent Kafka (в данном случае версии python) есть метод продукта, который принимает...
Я пытался запустить простое приложение для подсчета слов, используя Kafka, однако всякий раз, когда...
Это продолжение Чтение из ВСЕХ разделов в каждом экземпляре приложения Что я пытаюсь достичь, это...
В текущем проекте, над которым я работаю, мне нужно распаковать текстовые файлы (примерно 500Мб +...
Нашей целью является достижение следующей архитектуры.И самое главное - иметь возможность прочитать...
Сценарий использования заключается в том, что мой потребитель иногда выполняет некоторую работу...
При использовании KTable потоки Kafka не позволяют экземплярам читать из нескольких разделов...
Я пытаюсь зарегистрировать слушатель kafka вручную с помощью Spring Cloud Stream, однако у меня...
С моим курсом в универе я должен создать небольшой проект «больших данных».Для этого я собираю...
Я использую разъем приемника hbase для kafka (https://github.com/mravi/kafka-connect-hbase).)....
!! Тестовая среда Производитель, отправляющий сообщение с ключом 'A' раз в секунду. Kafka Streams...
Я загрузил Hortonworks Sandbox (IP: 192.179.144.XXX) на свой ноутбук с Windows 10.У меня запущена...
У меня есть тема, где публикуются события о файлах.По этой теме создается группировка с таблицей с...
Невозможно прочитать несколько URL-адресов из текстового файла для SSL Avro Producer...
Приложение My Kafka Streams использует тему kafka, которая использует следующую раскладку...
Для запуска cdc kafka connect на моем локальном компьютере с Ubuntu я запускаю его через отдельную...
У меня есть два объекта KTable: KTable<Long, byte[]> firstTable = builder
У меня есть тема с именем topic1 и тема с именем topic2 .У меня есть следующий код: - поток topic1...
Я использую confluent и в соответствии с официальным документом, мне нужно только настроить ниже в...
Попытка использовать confluent_kafka.AvroConsumer для получения сообщений с заданной отметкой...