У меня есть служба Kafka Stream, которая, по-видимому, ни по какой причине не начинает иметь...
У меня следующая проблема, может быть, кто-то может подсказать мне, где искать. мой проект: - kafka...
Какая из следующих рекомендаций является лучшей практикой для производственной среды: 1: Один поток...
Я пытаюсь присоединиться к KStream: создан из темы, тема имеет значение JSON. Я повторно набираю...
Я пытаюсь реализовать источник событий, используя kafka. Мое видение для приложения потокового...
У меня есть тема, в которой все журналы помещаются в централизованную тему, но я бы хотел...
Я изучал Kafka Streams API и реализовал пример WordCountExample в Scala, а также в Java, но когда я...
У меня есть тема, содержащая записи бухгалтерской книги, и я хочу получить к ним доступ в...
Как настроить потоки Кафки для использования следующего сообщения только при получении...
У нас есть несколько сообщений, последовательность которых нам нужна.Мы решили отправить все...
Я думаю, что что-то неправильно понял с помощью TopologyTestDriver. До сих пор, когда я...
Я пытаюсь отправить свои записи в нужную мне тему.Однако после того, как все записи были отправлены...
Я использую следующую топологию API процессора: Source: STopics (topics: [A, B, C]) --> P1...
Я делаю агрегацию в потоке тем Кафки и сохраняю в хранилище состояний в памяти.Хотелось бы узнать...
Я использую агрегацию KafkaStreams с пользовательским TimestampExtractor.Когда я перезапускаю...
У меня есть вопрос о шаблоне, который мы сейчас используем для планирования генерации сообщений на...
Для проекта я использую Spring Cloud Stream с Kafka в качестве связующего для нескольких приложений...
При запуске нашего приложения Kafka Streams в тестовой установке только с одним брокером Kafka мы...
Я пытаюсь скомпилировать код для классов интеграционных тестов, найденных в Confluent GitHub -...
Я делаю следующее: var listTopicOptions = ListTopicsOptions().listInternal(false) var topicsInKafka...
Я написал поток, который принимает сообщения и отправляет таблицу появившихся ключей.Если что-то...
Окно по сеансам из раздела просмотров страниц в KafkaStreams, логика агрегации может разбить сеанс...
Моя конфигурация для потребителя описана в Документация по свойствам потребителя Spring Cloud...
Я пытаюсь интегрировать трассировку Jaeger в K-Streams.Я планировал добавить трассировку к...
Мы используем Kafka и надеемся использовать интерактивные запросы , чтобы получить доступ к данным...