Raghu Angadi created BEAM-395:
---------------------------------
Summary: KafkaIO tests should be marked 'NeedsRunner'
Key: BEAM-395
URL: https://issues.apache.org/jira/browse/BEAM-395
Project: Beam
Issue Type: Bug
Components: sdk-java-extensions, testing
Affects Versions: 0.1.0-incubating
Reporter: Raghu Angadi
Assignee: Raghu Angadi
KafkaIO Tests are currently marked as 'RunnableOnService', which implies the
tests can run on any beam runner. This is not correct.
Though the tests are not runner dependent per se, they depend on mocks for
Kafka consumer and kafka producer. That requires the tests to be local to a
JVM. These tests can only run on single JVM runners like DirectRunner.
These tests should be marked 'NeedsRunner' for now.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
