)
at
kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60)
Thanks,
Jun
On Wed, Feb 4, 2015 at 12:58 AM, Sumit Rangwala sumitrangw...@gmail.com
wrote:
I am observing the following
I am observing the following exception with kafka client:
2015-02-04 00:17:27,345
(LAX1-GRIFFIN-r8-1423037468055-pf13797-lax1-GriffinDownloader-1423037818264_c7b1e843ff51-1423037822122-eb7afca7-leader-finder-thread)
ClientUtils$ WARN: Fetching topic metadata with correlation id 112 for
topics
-GRIFFIN-r4-1423119435925
LAX1-GRIFFIN-r5-1423119435923
LAX1-GRIFFIN-r6-1423119436354
LAX1-GRIFFIN-r7-1423119436095
LAX1-GRIFFIN-r8-1423119436100
LAX1-GRIFFIN-r9-1423119436377
Sumit
Sumit
Thanks,
Joel
On Wed, Feb 04, 2015 at 01:00:46PM -0800, Sumit Rangwala wrote:
I have
the topic with the default num.partitions and
replication.factor. Did you try stopping the consumer first and issue
the topic delete.
-Harsha
On Tue, Feb 3, 2015, at 08:37 PM, Sumit Rangwala wrote:
On Tue, Feb 3, 2015 at 6:48 PM, Harsha ka...@harsha.io wrote:
Sumit
On Tue, Feb 3, 2015, at 08:37 PM, Sumit Rangwala wrote:
On Tue, Feb 3, 2015 at 6:48 PM, Harsha ka...@harsha.io wrote:
Sumit,
lets say you are deleting a older topic test1 do you have any
consumers running simultaneously for the topic test1 while
deletion
and
replication.factor. Did you try stopping the consumer first and issue
the topic delete.
-Harsha
On Tue, Feb 3, 2015, at 08:37 PM, Sumit Rangwala wrote:
On Tue, Feb 3, 2015 at 6:48 PM, Harsha ka...@harsha.io wrote:
Sumit,
lets say you are deleting a older topic test1
at 04:11:57PM -0800, Sumit Rangwala wrote:
On Tue, Feb 3, 2015 at 3:37 PM, Joel Koshy jjkosh...@gmail.com
wrote:
Hey Sumit,
I thought you would be providing the actual steps to reproduce :)
I want to but some proprietary code prevents me to do it.
Nevertheless
logs at the very least and if possible server logs and send
those over?
Here are all the logs you requested (there are three brokers in my setup
k1, k2, k3): http://d.pr/f/1kprY/2quHBRRT (Gmail has issue with the file)
Sumit
Joel
On Tue, Feb 03, 2015 at 03:27:43PM -0800, Sumit Rangwala
On Tue, Jan 27, 2015 at 03:11:48PM -0800, Sumit Rangwala wrote:
I am using 0.8.2-beta on brokers 0.8.1.1 for client (producer and
consumers). delete.topic.enable=true on all brokers. replication factor
is
number of brokers. I see this issue with just one single topic, all
other
, Sumit Rangwala wrote:
While running kafka in production I found an issue where a topic wasn't
getting created even with auto topic enabled. I then went ahead and
created
the topic manually (from the command line). I then delete the topic,
again
manually. Now my broker won't allow me to either
I was planning to start a new thread by my experience is similar to the one
described here. I am currently using 0.8.2-beta and my setup has a producer
producing to topic DC-DATA, kafka brokers with auto-topic-creation
enabled, and mirrormaker set to replicate any .*-DATA topics. After the
While running kafka in production I found an issue where a topic wasn't
getting created even with auto topic enabled. I then went ahead and created
the topic manually (from the command line). I then delete the topic, again
manually. Now my broker won't allow me to either create *the* topic or
, which
also includes cleaning the logs and removing it from zookeeper (once
it is fully deleted).
Tim
On Fri, Jan 23, 2015 at 12:13 PM, Sumit Rangwala
sumitrangw...@gmail.com wrote:
I am trying to find if there is a supported API to delete topic (from
within my code) specifically
13 matches
Mail list logo
