public static < Message > Topic < Message > singleStreamWithOffset ( Function < Offset , Source < Pair < Message , Offset > , ? > > eventStream ) { return taggedStreamWithOffset ( SINGLETON_TAG , ( tag , offset ) -> eventStream . apply ( offset ) ) ; }
Publish a single stream .