Я бы хотел настроить стратегию именования субъектов схемы Avro в источниках, потребителях и...
Есть ли способ обработать динамическое условие в потоке кафки? Мне нужно отфильтровать мои...
В моем приложении структурированного потокового вещания я читаю сообщения от Кафки, фильтрую их и,...
Примеры приложений для проверки этого можно найти в https://github
Я пытался создать производителя и потребителя в Кафке на Linux-машине.Я запустил экземпляр...
У меня есть тема kafka, по которой я отправляю данные через Kafka Producer. Теперь на стороне...
Я использовал spring-cloud-starter stream-kafka для подключения к kafka, версия 2.1.2.Когда я...
У меня есть приложение (spring-boot-shipping-service) с KStream, которое получает сообщения...
Я не могу сохранить структурированные потоковые данные из Kafka в MongoDB.Это первый раз, когда я...
Фильтр Kafka из нескольких тем по темам. kafka_stream = KafkaUtils.createStream(ssc,...
Я новичок в архитектуре микросервисов. Я пытаюсь учиться на онлайн-ресурсах. Так что мой вопрос...
Я установил kafka локально (на данный момент нет реестра кластера / схемы) и пытаюсь создать тему...
Я хотел бы использовать как Processor API, так и DSL в одном приложении потоков Kafka. Кроме того,...
У меня есть CSV-файл, в котором есть столбцы, и для целей тестирования я помещаю его вручную в...
У нас есть производитель Kafka, который генерирует сообщения с очень высокой частотой для тем,...
Я запускаю зоопарка и сервер Kafka из Java-приложения. Если я попытаюсь уничтожить эти процессы,...
У нас есть 3 узла кластера kafka с примерно 32 темами и 400+ разделами. распространяться по этим...
Я использую Spring Cloud Finchley.RELEASE с RocksDb и Kafka-Streams для производственного...
У меня есть вопрос с потоковой передачей в целом, но для целей вопроса давайте ограничимся Kafka...
Предположим, что приложение Spring Cloud Stream создает KStream из order topic.Интересует...
Я использую Kafka Streams, и я заметил, что это приводит к тому, что моя kafka записывает в журнал...
Это мое приложение, которое просто получает ссылку на KStream из темы клиента (привязка ввода) и...
мы хотим читать данные из kafka, которые дают данные 70 и т. Д. За 500 мс со структурированной...
Я хочу перезаписать GlobalKTable (возможно, при его инициализации, поскольку я считаю, что они...
У меня есть две темы, одна с 3 разделами и одна с 48. Первоначально я использовал назначитель по...