sclasen / akka-kafka

185 stars 62 forks source link

Question, how to set SupervisorStrategy for StreamFSM? #55

Open kuizhang opened 7 years ago

kuizhang commented 7 years ago

Pardon me for English is not my primary language.

We have size limitation on the messages so that StreamFSM.hasNext() will receive a MessageSizeTooLargeException when encountering a too large message. The default SupervisorStrategy behavior is simply restart the process. Since nothing changed the process gets stuck with this ill message forever.

We'd like to recover this error by moving offset to next so that we can skip this message and restart the process. However we could not find a way to set SupervisorStrategy for the framework and change the default behavior. I am wondering if there is a way for us to do so?