Jakob Homan created SAMZA-83:
--------------------------------
Summary: Discard rather than throw exception for Kafka topics with
non-existent partitions
Key: SAMZA-83
URL: https://issues.apache.org/jira/browse/SAMZA-83
Project: Samza
Issue Type: Bug
Components: kafka
Affects Versions: 0.7.0
Reporter: Jakob Homan
Assignee: Jakob Homan
Fix For: 0.7.0
KafkaSystemConsumer, 117:
{code} val brokerOption = partitionMetadata(topicAndPartition.topic)
.partitionsMetadata
.find(_.partitionId == topicAndPartition.partition)
.getOrElse(toss("Can't find leader for %s" format
topicAndPartition))
.leader{code}
In conjunction with SAMZA-82, we can't ready kafka streams with different
number of partitions, since we throw exceptions for those topics that we
speculatively created. This is short term fix; the more correct approach is
SAMZA-82.
--
This message was sent by Atlassian JIRA
(v6.1#6144)
