то есть обработка приходящих данных, и форвардинг их в другие топики? А не просто для обработки данных и использования их в этом же сервисе
Стикер
Ну форвардинг будет в пределах 1 сервиса(того же инстанса)
ну отправка в условный дев нул тоже форвардинг) а в трасформере логику реализовываем и работаем
Думал его суть в том, чтобы обработать стрим, и перенаправить его в другой топик, и уже другие сервисы будут эти топики с обработаннанными данными использовать. Но как я понял, можно и самому их юзать после обработки
прикол стримов что они типа гарантируют строго разовую обработку если нет сайд эффектов и есть только чтение-трансформация-отправка. В остальных случаях это просто обертка с которой иногда проще иногда сложнее работать чем с тем же нативным консумером
Можно не только в топики Преобразование потоков данных, соединение потоков, передача из Kafka в RabbitMQ
Обсуждают сегодня