questions/apache-kafka
To delete all the messages from a Kafka topic. There are many approach ...READ MORE
Hi@akhtar, Actually, in kafka there is no command ...READ MORE
System.out.println(String.valueOf(output.offset()) + ": " + new String(bytes, ...READ MORE
If your service, in this case kafka, ...READ MORE
Hi@akhtar, Bootstrap.servers is a mandatory field in Kafka ...READ MORE
HI@akhtar, You get this error because before stating ...READ MORE
The reset option only prints the result ...READ MORE
Hi@akhtar, To know leader information you can use ...READ MORE
These are the steps to install Kafka ...READ MORE
Hi@akhtar, Kafka uses ZooKeeper, so you need to ...READ MORE
Hi@akhtar, Here the zookeeper service is already started ...READ MORE
kafka-run-class.bat kafka.tools.ConsumerOffsetChecker --broker-info --group test-consumer-group --topic test ...READ MORE
Hi@prasant, I am not sure it will work ...READ MORE
I just would like to complete the ...READ MORE
In general, a single producer for all ...READ MORE
Hi@akhtar, In your file bootstrap.servers field in missing. ...READ MORE
sudo systemctl status kafka This should at least ...READ MORE
Hi@akhtar, To install sbt in your RedHat system ...READ MORE
Hi@akhtar, To fix the pipeline, you need to resolve ...READ MORE
It is working for me with below ...READ MORE
Hi@akhtar, You have to read the messages normally ...READ MORE
Hi@akhtar, It defines how many time the producer ...READ MORE
Yes. There is one Tool Name Called ...READ MORE
Hi@akhtar, This error occurs because zookeeper is running already. So ...READ MORE
Hi@ I don't know it will work or ...READ MORE
Hi@Amit, You can pass --offset keyword in your ...READ MORE
Hi@akhtar, Before starting confluent kafka in your system, ...READ MORE
You can use auto.commit.enable to allow Kafka ...READ MORE
First of all, Consumer is not thread ...READ MORE
Hi@Rishabh, I think to implement this task you ...READ MORE
By default in Kafka version 0.10, delete.topic.enable ...READ MORE
You need to add the hostname in ...READ MORE
rebalance.backoff.ms defines the time for which Kafka ...READ MORE
Hi@akhtar, I guess you are using the old ...READ MORE
Hi@B, There may be a problem with your ...READ MORE
Easy Approach is work with Docker. ConfluentInc ...READ MORE
For your case what you can do ...READ MORE
Hi@akhtar, You can change the default directory in ...READ MORE
If you know the limit of API ...READ MORE
The output to download this is in ...READ MORE
Hi@akhtar, As the above error shows that the ...READ MORE
Yes, it stays the same. An offset is ...READ MORE
I am not sure what you expect ...READ MORE
Hi@akhtar, Before you start the Zookeeper service, you need ...READ MORE
The most important elements of Kafka: Topic – ...READ MORE
Hi@progDuck, By default it is connecting to localhost:2181, ...READ MORE
Already that day in a row I ...READ MORE
Hi@akhtar, To do this task you have to ...READ MORE
Deleting topic isn't always working in 0.8.1.1 Deletion ...READ MORE
Getting below warning in zookeeper log 2021-02-19 14:20:27,911 ...READ MORE
OR
At least 1 upper-case and 1 lower-case letter
Minimum 8 characters and Maximum 50 characters
Already have an account? Sign in.