search

lovoo / goka

Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.
BSD 3-Clause "New" or "Revised" License
2.36k stars 173 forks source link

How to get Lookup tables to work with processors? #452

Closed akshatraika-moment closed 5 months ago

akshatraika-moment commented 6 months ago

Trying to figure out how to get Lookup tables to work with processors. It looks like the View intialization in the processor for look up tables does not have goka.WithViewAutoReconnect() configured on them which leads to the processor to always exit out with an error from kafka consumer reaching EOF.

Error:

 error running lookup table my_lookup_table_topic: 1 error occurred:
    * Error catching up partitions for view my_lookup_table_topic: 1 error occurred:
    * kafka: error while consuming my_lookup_table_topic/0: EOF