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
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?