Hi,
sorry for dropping this one. I totally forgot this thread.
Did you find a solution?
One reason for this to happen could be that you specified only one broker
in the list of bootstrap severs?
On Wed, Apr 20, 2016 at 7:08 PM, Balaji Rajagopalan <
balaji.rajagopa...@olacabs.com> wrote:
> Robert
Robert,
Sorry I gave the information about wrong topic. Here is the right one.
balajirajagopalan@megatron-server02:/usr/share/kafka_2.11-0.8.2.1/bin$
./kafka-topics.sh --describe --topic location --zookeeper (someserver)
Topic:location PartitionCount:150 ReplicationFactor:1 Configs:
Topic: loca
/usr/share/kafka_2.11-0.8.2.1/bin$ ./kafka-topics.sh --describe --topic
capi --zookeeper (someserver)
Topic:capi PartitionCount:1 ReplicationFactor:1 Configs:
Topic: capi Partition: 0 Leader: 0 Replicas: 0 Isr: 0
There are no events to consume from this topic, this I confirm by running
the cons
Hi,
I just tried it with Kafka 0.8.2.0 and 0.8.2.1 and for both versions
everything worked fine.
How many partitions does your topic have?
Can you send me the full logs of the Kafka consumer?
On Tue, Apr 19, 2016 at 6:05 PM, Balaji Rajagopalan <
balaji.rajagopa...@olacabs.com> wrote:
> Flink ver
Flink version : 1.0.0
Kafka version : 0.8.2.1
Try to use a topic which has no message posted to it, at the time flink
starts.
On Tue, Apr 19, 2016 at 5:41 PM, Robert Metzger wrote:
> Can you provide me with the exact Flink and Kafka versions you are using
> and the steps to reproduce the issue?
Can you provide me with the exact Flink and Kafka versions you are using
and the steps to reproduce the issue?
On Tue, Apr 19, 2016 at 2:06 PM, Balaji Rajagopalan <
balaji.rajagopa...@olacabs.com> wrote:
> It does not seem to fully work if there is no data in the kafka stream,
> the flink applica
It does not seem to fully work if there is no data in the kafka stream, the
flink application emits this error and bails, could this be missed use case
in the fix.
On Tue, Apr 19, 2016 at 3:58 PM, Robert Metzger wrote:
> Hi,
>
> I'm sorry, the documentation in the JIRA issue is a bit incorrect.
Hi,
I'm sorry, the documentation in the JIRA issue is a bit incorrect. The
issue has been fixed in all versions including and after 1.0.0. Earlier
releases (0.10, 0.9) will fail when the leader changes.
However, you don't necessarily need to upgrade to Flink 1.0.0 to resolve
the issue: With checkp
I am facing this exception repeatedly while trying to consume from kafka
topic. It seems it was reported in 1.0.0 and fixed in 1.0.0, how can I be
sure that is fixed in the version of flink that I am using, does it require
me to install patch updates ?
Caused by: java.lang.RuntimeException: Unabl
