[
https://issues.apache.org/jira/browse/BEAM-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766129#comment-16766129
]
Alexey Romanenko commented on BEAM-2466:
----------------------------------------
[~teabot]
1) I'm not very familiar with KStreams API. Does it require to have Kafka topic
as input in any case? Does KStreams source heavily linked with Kafka topics?
2) "Only streaming support" - well, this is kind of against initial Beam idea
of easily switching between batch and streaming pipelines (since it won't be
possible to use KafkaRunner for other pipelines, written in traditional Beam
way). So, it's quite serious limitation, imho, but, perhaps, there could be
some workarounds for that.
> Add Kafka Streams runner
> ------------------------
>
> Key: BEAM-2466
> URL: https://issues.apache.org/jira/browse/BEAM-2466
> Project: Beam
> Issue Type: Wish
> Components: runner-ideas
> Reporter: Lorand Peter Kasler
> Assignee: Kai Jiang
> Priority: Minor
> Labels: triaged
>
> Kafka Streams (https://kafka.apache.org/documentation/streams) has more and
> more features that could make it a viable candidate for a streaming runner.
> It uses DataFlow-like model
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
