У нас есть приложение для потоковой обработки, и в потоке мы извлекаем id и сохраняем его в...
У меня есть приложение Kafka Streams, работающее на нескольких JVM (всего 5) для повышения...
Я использую Pipe.java, как указано в примере API потока https://kafka.apache
Я столкнулся с очень странной проблемой, Could not find a "KafkaClient" entry in the JAAS...
Я новичок в GCP. Я создал кластер Multinode Kafka и Zookeeper в облачной платформе Google. Я могу...
Скажем, например, у меня есть 4 раздела. Когда сообщение msg1 из ключ 101 помещается в раздел 1 (...
У меня есть служба REST python, которая получает запросы, содержащие определение схемы Avro и...
У меня кластер Kafka из 10 машин. Конфигурация Kafka xmx теперь составляет 8 г. Однако после...
У меня есть тема, содержащая записи бухгалтерской книги, и я хочу получить к ним доступ в...
Я думаю, что что-то неправильно понял с помощью TopologyTestDriver. До сих пор, когда я...
Я следовал этому учебнику , и когда я попытался запустить его на GKE, я не смог запустить kafka pod
Я пытаюсь отправить свои записи в нужную мне тему.Однако после того, как все записи были отправлены...
Я строю чтение конвейера Apache Beam из Kafka, используя KafkaIO, но я не уверен, как решить...
Я делаю репликацию данных в кафке.Но размер файла журнала kafka увеличивается очень быстро.Размер...
Для проекта я использую Spring Cloud Stream с Kafka в качестве связующего для нескольких приложений...
Я пытаюсь построить конвейер данных от MySql до Ksql . Сценарий использования: источником данных...
Я пытаюсь скомпилировать код для классов интеграционных тестов, найденных в Confluent GitHub -...
Я делаю репликацию данных в alpakka, используя Consumer.commitableSource.Но размер файла журнала...
Я написал поток, который принимает сообщения и отправляет таблицу появившихся ключей.Если что-то...
Я строю кластер с использованием CDH5.14.2, включает в себя 5 узлов, каждый узел имеет 130G памяти...
Я пытаюсь интегрировать трассировку Jaeger в K-Streams.Я планировал добавить трассировку к...
В настоящее время я создаю kafka потребитель в Java, где он будет отображать только разделы (у меня...
Я столкнулся с проблемой с TopologyTestDriver, так как необходимо установить свойство:...
У меня есть простая схема avro, и я добавил одно новое поле в схему avro, указав значение по...
Я получил грязный код с debezium: "doulist_name": "2013...