Hi all,

For the moment, I'm working on BEAM-4048 
<https://issues.apache.org/jira/browse/BEAM-4048> to add Kafka source/sink 
support with different modes to Nexmark, like it has for PubSub 
(SUBSCRIBE_ONLY, PUBLISH_ONLY and COMBINED). It seems that the code will be 
similar to what we have for PubSub so I wanted to do some refactoring and reuse 
already existed code for Kafka. So, to make sure that nothing will be broken 
after this refactoring, I want to run Nexmark with PubSub source/sink in 
different modes before and after. 

I tried to do this with PubSub emulator but I have very strange issue related 
to pipeline serialisation - it tries to serialise NexmarkLauncher, see this 
output <https://gist.github.com/aromanenko-dev/a42a0a011f9fbd10b8443bf2ca38c68a>

Could anyone point me out if I do something wrong running this Nexmark pipeline 
and how properly to do it with PubSub as source/sink? 


Reply via email to