apache-kafka-streams
Kafka: Consumer API vs Streams API
Ostatnio zacząłem uczyć się Kafki i kończę z tym pytaniem.
Jaka jest różnica między konsumentem a strumieniem? Dla mnie, je ... iej?
I did Google na to, ale nie dostał żadnych dobrych odpowiedzi na to. Przepraszam, jeśli to pytanie jest zbyt trywialne.
Jak wysłać ostateczny wynik agregacji kafka-streams w oknie czasowym?
To co chciałbym zrobić to:
zużywaj rekordy z tematu liczb (Long ' S)
Agregat (count) wartości dla każdego okna 5 sek
Wyś ... lowego dla każdego przychodzącego rekordu. Moje pytanie brzmi: Jak mogę wysłać tylko ostateczny wynik agregacji każdego okna?