What you are actually asking is if Kafka Streams should be reimplemented as
Apache Storm?
-wim
On Wed, 29 Nov 2017 at 15:10 Adrienne Kole wrote:
> Hi,
>
> The purpose of this email is to get overall intuition for the future plans
> of streams library.
>
> The main question is that, will it be a
[
https://issues.apache.org/jira/browse/KAFKA-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020920#comment-16020920
]
Wim Van Leuven commented on KAFKA-5253:
---
Can anybody give direction in ho
Wim Van Leuven created KAFKA-5253:
-
Summary: KStreamTestDriver must handle streams created with
patterns
Key: KAFKA-5253
URL: https://issues.apache.org/jira/browse/KAFKA-5253
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961720#comment-15961720
]
Wim Van Leuven commented on KAFKA-4927:
---
just committed the changes to f
[
https://issues.apache.org/jira/browse/KAFKA-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wim Van Leuven updated KAFKA-4927:
--
And? Needs tweaking?
> KStreamsTestDriver fails with NPE when KStream.to() sinks are u
[
https://issues.apache.org/jira/browse/KAFKA-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960721#comment-15960721
]
Wim Van Leuven commented on KAFKA-4927:
---
What needs to happen to get this PR me
[
https://issues.apache.org/jira/browse/KAFKA-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wim Van Leuven updated KAFKA-4927:
--
Summary: KStreamsTestDriver fails with NPE when KStream.to() sinks are used
(was
[
https://issues.apache.org/jira/browse/KAFKA-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wim Van Leuven updated KAFKA-4927:
--
Summary: KStreamsTestDriver fails with NPE when Topic sinks are used (was:
KStreamsTestDriver
Wim Van Leuven created KAFKA-4927:
-
Summary: KStreamsTestDriver fails with NullPointerException when
Topic sinks are used
Key: KAFKA-4927
URL: https://issues.apache.org/jira/browse/KAFKA-4927
Project
