Ok. The is fixed in the 0.8.1 release, which is being voted now. Thanks,
Jun On Thu, Mar 6, 2014 at 9:34 AM, David Morales de Frías < dmora...@paradigmatecnologico.com> wrote: > 0.8, thanks. > > > 2014-03-06 18:27 GMT+01:00 Jun Rao <jun...@gmail.com>: > > > Which version of Kafka are you using? > > > > Thanks, > > > > Jun > > > > > > On Thu, Mar 6, 2014 at 2:10 AM, David Morales de Frías < > > dmora...@paradigmatecnologico.com> wrote: > > > > > Hi there, > > > > > > If i start a consumer in a non-existent topic (auto-create true) before > > the > > > producer, the consumer never gets the messages. > > > > > > These are the steps: > > > > > > 1) kafka-console-consumer --topic newTopic (it doesn't exist) > > > 2) kafka-console-producer --topic newTopic > > > 3) Send some messages > > > 4) I can see this in the log and the consumer never receives them > > > > > > [2014-03-06 10:58:18,641] WARN Error while fetching metadata > > > [{TopicMetadata for topic newTopic -> > > > No partition metadata for topic newTopic due to > > > kafka.common.LeaderNotAvailableException}] for topic [newTopic]: class > > > kafka.common.LeaderNotAvailableException > > > (kafka.producer.BrokerPartitionInfo) > > > > > > > > > > > > 5) restart kafka-console-consumer --topic newTopic > > > 6) Send some messages from producer > > > 7) Consumer receives messages. > > > > > > > > > > > > Is that ok? > > > Where are the produced messages? I'm sure that consumer never see them, > > but > > > are they stored in brokers? > > > > > > > > > Regards. > > > > > >