Как я могу получить последние N записей из потока, используя Kafka KSQL - PullRequest
0 голосов
/ 05 марта 2020

Предположим, у меня есть поток, который содержит цены на акции. Каждая запись состоит из

  • тикер

  • цена

например

  • AAPL, 102,23
  • FB, 23,34
  • AAPL, 101,99
  • AMZN, 45,43
  • ...

Мне нужно получить последние 60 ценовых записей для AAPL. Я не хочу использовать время windows - только последние 60 записей.

...