These are chat archives for akkadotnet/AkkaStreams

16th
Aug 2018
Bartosz Sypytkowski
@Horusiath
Aug 16 2018 06:39
@AndreSteenbergen I've asked akka people how they handle this case - IMHO, even if we're going to handle it via specific message, it probably should be a something that can be clearly recognized as EOF (not by comparing message header type to some binary value, more like flag or event dedicated event type).
AndreSteenbergen
@AndreSteenbergen
Aug 16 2018 14:18
@Horusiath I guess a derived type, from ConsumerRecord<K,V> could handle that; the ReceiveMessage would be a little more work, creating the derived type instead of the base type it receives.