KAFKA (0.10.0.0) - Error while fetching metadata with correlation id

2017-03-09 Thread Barot, Abhishek
Hi, We are running KAFKA 0.10.0.0 but at times I see below error while starting STORM topologies. org.apache.kafka.clients.NetworkClient WARN - Error while fetching metadata with correlation id 325376 : {aceb3102-62d9-4809-b01b-6c69ebacbc90=UNKNOWN} Looks like KAFKA consumer i

Topic with retention period of 10 mins

2017-01-24 Thread Barot, Abhishek
Hi Kafka-users, We've set up a KAFKA(0.10.0.0) topic to feed to elasticsearch so that we can view the stuff on Kibana dashboard but the problem I'm running into is that topic apparently gets flooded with loads and loads of data and we've got limited Disk space on the server to utilize. So in ord

Failing to get Topic Configuration

2017-01-20 Thread Barot, Abhishek
Hi Kafka-users, Could anyone help me suggest why am I not able to get the topic configuration by running below command $ ./kafka-configs.sh --zookeeper *a.b.c.d:2181/kafka --describe --entity-name test --entity-type topics Configs for topics:test are $ *a.b.c.d - private url where zookeeper is

Kafka - topics not getting deleted

2017-01-17 Thread Barot, Abhishek
Hi Kafka-users, Could anyone please suggest why am I not being able to delete the kafka topic from broker. Below are the commands I've executed $ ./kafka-topics.sh --list --zookeeper /kafka Shows ProducerConsumerOffsetTestTopic001 - marked for deletion $ ./kafka-topics.sh --describe -zookee