Commands to create, delete, alter topics, acls config
When kafka consumers are subscribing to a topic, as and when messages are produced, they are consumed by the consumers. But due to high traffic or latency or high load issues, there would be a lag in consuming the messages. With Kafka binaries it is possible to know the lag Read more…
Status of offsets of consumer groups are stored on Kafka broker. If that should be reset, for ex based on a duration ./bin/kafka-consumer-groups –bootstrap-server kafkaserver:9092 –group consumergroupname –reset-offsets –by-duration 1522760000 –execute If that should be reset, for ex based on a timestamp ./bin/kafka-consumer-groups –bootstrap-server kafkaserver:9092 –group consumergroupname –reset-offsets –to-datetime 2019-08-28T19:45:00.000 Read more…
With curl commands, schemas can be retrieved/updated to Confluent SchemaRegistry. Get the latest schema available on the topic: curl -X GET http://localhost:8081/subjects/testtopic-value/versions/latest Get Schema compatibility: curl -X GET http://localhost:8081/config/testtopic-value Get versions of all registered schemas on a topic: curl -X GET http://localhost:8081/subjects/testtopic-value/versions [1,2,3] List all subjects – registered schemas on Read more…
Acl stand for Access control list. Acls are added on resources like topics or group to provide authorization to producers or consumers. Acls can be added with specific parameters like operation or producer or consumer. Below I will provide few commands to add acls in different ways. Add an Acl Read more…
Add one kafka topic with 2 replicas and 4 partitions with the below command Add multiple kafka topics with 2 replicas and 4 partitions with the below command