This is an automated email from the ASF dual-hosted git repository.
kamir pushed a change to branch kamir-patch-1
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
from eff302f1 Update backend.yml
add 31cdbffd deactivated non relevant tests - KafkaTopicSource,
JavaKafkaTopicSource
add 2d56229f Merge branch 'kamir-patch-1' of
https://github.com/apache/incubator-wayang into kamir-patch-1
No new revisions were added by this update.
Summary of changes:
.../wayang/basic/operators/KafkaTopicSource.java | 62 ++++++++++++++--------
wayang-platforms/wayang-java/pom.xml | 7 +++
.../java/operators/JavaKafkaTopicSource.java | 4 +-
.../java/operators/JavaKafkaTopicSourceTest.java | 12 +++--
.../apache/wayang/java/test/KafkaClientTest.java | 57 +++++++++++++++-----
5 files changed, 99 insertions(+), 43 deletions(-)
