Я пытаюсь прочитать полные данные / записи из таблицы ktable, но я заметил, что я могу видеть...
Пытаясь лучше понять, как настроить мой кластер для запуска моего приложения Kafka-Stream, я...
Я выполнил определенное требование и хотел бы услышать мнение людей и, конечно, не изобретать...
Я пытаюсь понять обходной путь, который упоминается в: https://issues.apache
У меня есть ситуация, когда мне нужно дополнить несколько (15) полей дополнительными данными....
Я пытаюсь распространять сообщения kafka по моей теме, которая состоит из четырех разделов, но у...
Я импортирую БД, которая содержит некоторую таблицу ссылок, представляющую отношения «многие ко...
Я должен сосчитать различные события во временном интервале.У меня есть события, связанные с...
У нас есть следующие требования к обработке потока. Source Stream -> transform(condition check -...
У меня есть записи, поступающие в kafka с несколькими неуникальными полями, давайте назовем их...
У меня есть топология, которая вычисляет количество раз, когда определенный IP-адрес замечен, и это...
Я храню сообщения из темы Kafka в KeyValueStore, чтобы я мог запросить их позже. Я создаю таблицу...
Мой вариант использования - получить последнее значение для любой ключ в теме Кафки.Для этого я в...
Кафка стрим / Ksql на самом деле как-то изначально поддерживает json?Какие другие форматы...
У меня есть события, приходящие в Кафку с кучей неуникальных полей String и отметкой времени...
Я пишу приложение Kafka Streams.Он выполняет следующие шаги: «1) использует входные данные 2)...
У меня есть несколько устройств IOT, которые сообщают о событиях через сообщения в тему kafka, и я...
Сообщения, отбрасываемые из-за истекших окон, даже если для этого конкретного ключа окно не должно...
Есть отличная серия статей о транзакциях Kafka и о точной доставке. В одном из них автор говорит о...
Я пытаюсь посчитать количество конвертов из темы.Сделка в авро-формате.Я использую этот пример в...
Я пытался написать модульный тест для класса, реализующего интерфейс Processor, который содержал...
В теме содержится 10 разделов, сообщения которых генерируются каждые 3-4 секунды различными...
Я надеюсь прояснить несколько идей о потоках Кафки с архитектурной точки зрения. Я понимаю, что...
Возможно ли после получения сигнала завершения работы (kill) мы можем отправить уведомление потокам...
Когда я выполняю свое приложение для обработки данных, используя Embedded Kafka Streams для...