Reset Kafka offsets

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…

Commands for SchemaRegistry

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…