Could you reproduce this easily? Thanks,
Jun On Thu, Sep 5, 2013 at 10:52 AM, Ian Friedman <i...@flurry.com> wrote: > It shouldn't be, no… it returns an ImmutableMap.. > > setTopicMap(ImmutableMap.of(KafkaLogQueuer.sKafkaDataLogPathsTopic, 1)); > > -- > Ian Friedman > > > On Wednesday, September 4, 2013 at 11:40 PM, Jun Rao wrote: > > > What createMessageStreams() returns should match what's in the input. Is > it > > possible for getTopicMap() to return an empty map? > > > > Thanks, > > > > Jun > > > > > > On Wed, Sep 4, 2013 at 1:43 PM, Ian Friedman <i...@flurry.com (mailto: > i...@flurry.com)> wrote: > > > > > Hey gang, I have a strange intermittent issue with our 0.7.2 consumers > > > that is perpelxing me: > > > > > > It seems like, sometimes very infrequently, when restarting our > Consumer > > > fleet, some consumers threads just fail to start. The consumer > connector > > > itself starts fine, and seems to be involved in subsequent rebalances, > but > > > based on the logging I'm seeing, it looks like our one call to > > > ConsumerConnector.createMessageStreams is returning an empty map. > > > > > > Is that something that should happen normally and should we be > retrying in > > > our calling code? Our consumer code looks like this: > > > > > > Map<String, List<KafkaStream<Message>>> topicMessageStreams = > > > fConsumerConnector.createMessageStreams( getTopicMap() ); > > > > > > for( Map.Entry<String, List<KafkaStream<Message>>> entry : > > > topicMessageStreams.entrySet() ) > > > { > > > final String topicName = entry.getKey(); > > > log.info (http://log.info)( "starting stream for topic: " + topicName > ); > > > final KafkaStream<Message> stream = entry.getValue().get(0); > > > > > > …. > > > > > > Are we doing anything dumb here? In the case I described, we're never > > > getting the "starting stream for topic: " message in our log output, > so my > > > only guess is that createMessageStreams is returning an empty map. > > > > > > Thanks in advance guys! > > > > > > -- > > > Ian Friedman > > > > > > > > > > > >