GitHub user kawamuray opened a pull request:
https://github.com/apache/kafka/pull/1289
KAFKA-3642: Fix NPE from ProcessorStateManager when the changelog topic not
exists
Issue: https://issues.apache.org/jira/browse/KAFKA-3642
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kawamuray/kafka KAFKA-3642-streams-NPE
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/1289.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1289
----
commit 189571f9ab6555cc420190a9fb38ab2064ce42ab
Author: Yuto Kawamura <[email protected]>
Date: 2016-04-29T16:53:38Z
KAFKA-3642: Fix MockConsumer#partitionsFor to behave as same as
KafkaConsumer
KafkaConsumer#partitionsFor returns null when the topic not exists.
commit f8d96209c97eef4328f6255f6a43ae0c2c70543b
Author: Yuto Kawamura <[email protected]>
Date: 2016-04-29T16:22:00Z
KAFKA-3642: Make ProcessorStateManager throw meaningful exception instead
of NPE when topic not exists
commit f1cae8eb977965ec82a60ea45bdbe5c1ecee869a
Author: Yuto Kawamura <[email protected]>
Date: 2016-04-29T16:23:50Z
KAFKA-3642: Warn if expected internal topic not exists when
zookeeper.connect isn't supplied
commit 4f7c6dc9becb547368f5dac6d508bd071bdfec91
Author: Yuto Kawamura <[email protected]>
Date: 2016-04-29T16:26:39Z
MINOR: Remove meaningless branching argument
- It doesn't hurts anything even always return filled list
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
