Мы создаем Java-приложение, которое будет использовать встроенный Neo4j для обхода графа.Ниже...

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

Я использую встроенный Kafka для junit и хочу установить каталог состояния для встроенного Kafka. Я...

Я использую Apache Kafka в качестве обработчика сообщений и использую Confluent.Kafka в Asp.Net...

Я сохранил данные в формате Avro (Generic Record) в Kafka и затем извлек их. Данные состоят из 2...

Я пишу простой продюсер, я просто хочу отправить необработанные данные в тему. по какой-то причине...

Я настроил приложение Spring Cloud Stream Kafka для использования транзакций ( полный исходный код...

Мне нужно установить свойство 'group.id' в моем приложении KSQL. Я знаю, что это возможно в...

Есть отличная серия статей о транзакциях Kafka и о точной доставке. В одном из них автор говорит о...

Я пытаюсь посчитать количество конвертов из темы.Сделка в авро-формате.Я использую этот пример в...

нетто и кафка. Я использую последнюю версию Kafka в .Net. Я пытаюсь написать код для batchproducer....

Я пытался написать модульный тест для класса, реализующего интерфейс Processor, который содержал...

У меня есть кластер kafka на докере, использующий слившиеся изображения. Я использую docker-compose...

В теме содержится 10 разделов, сообщения которых генерируются каждые 3-4 секунды различными...

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

Возможно ли после получения сигнала завершения работы (kill) мы можем отправить уведомление потокам...

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

Можно ли отправить объект Java в качестве значения в теме Kafka и как мне использовать его в spark?...

У меня есть приложение akka (в JAVA), которое использует commitablePartitionedSource для получения...

Изначально я сделал более сложное приложение kstream, которое делало много сложных вещей.Работая в...

Я управлял брокером зоопарка и кафкой, но я не руководил производителем кафки.Я запустил код...

Я хочу использовать kafka-jms-client для замены моего текущего jms-брокера. Согласно документации...

Давайте предположим простой случай, подобный следующему: ORDER_TOPIC ----> KSTREAM ---->...

У меня есть сценарий использования, в котором я должен подписаться на несколько тем в kafka в...

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