The Kafka Java Admin client is actively being worked on now as part of
KIP-4
see https://issues.apache.org/jira/browse/KAFKA-1694
specifically sub-task #9 Create Java Admin Client
The Server side and wire protocol for admin commands like
create/delete/modify topic are already in Kafka 0.10.1
-h
Are you looking something like this
String command = String.format("--delete --zookeeper %s --topic %s",
"localhost:2181", "test_topic");
String[] split = command.split(" ");
TopicCommand.main(split);
t
SunilKalva
On Mon, Oct 24, 2016 at 9:09 PM, Ali Akhtar wrote:
> There isn't a java API for
There isn't a java API for this, you'd have to mess around with bash
scripts which I haven't found to be worth it.
Just let the data expire and get deleted. Set a short expiry time for the
topic if necessary.
On Mon, Oct 24, 2016 at 6:30 PM, Demian Calcaprina
wrote:
> Hi Guys,
>
> Is there a w
ka to remove all
the messages. If you turn on the ability to delete topics, you can also then
delete them.
-Dave
-Original Message-
From: Demian Calcaprina [mailto:calcacue...@gmail.com]
Sent: Monday, October 24, 2016 8:31 AM
To: users@kafka.apache.org
Subject: Removing kafka topic con
Hi Guys,
Is there a way to remove a kafka topic from the java api?
I have the following scenario:
We have a subscription service, which returns responses to subscribed
clients through kafka topic. Per subscription, we create a new kafka topic
and send the data by publishing in this new topic. And
Hi Guys,
Is there a way to remove a kafka topic from the java api?
I have the following scenario:
We have a subscription service, which returns responses to subscribed
clients through kafka topic. Per subscription, we create a new kafka topic
and send the data by publishing in this new topic. And
