- The idea behind the app is to allow you to manually set offsets in kafka.
- You can move to a custom offset or move to the beginning or end of a topic
- You need to make sure that all consumers to a particular consumer group should be stopped before starting this app.
./gradlew bootRun
Setting Custom Offsets
POST localhost:8082/kafka-offset-manager/custom-offset
POST BODY:
{
"consumerGroupId" : "consumer1",
"kafkaBroker" : "localhost:9092",
"topic": "test",
"partitionOffsets": [{"partition": "0", "offset": "29753"}, {"partition": "1", "offset": "30595"}]
}
Moving the offsets to the earliest available offset:
POST localhost:8082/kafka-offset-manager/boundary?position=start
POST BODY:
{
"consumerGroupId" : "consumer1",
"topic": "test",
"kafkaBroker" : "localhost:9092"
}
Moving the offsets to the latest available offset:
POST localhost:8082/kafka-offset-manager/boundary?position=end
POST BODY:
{
"consumerGroupId" : "consumer1",
"topic": "test",
"kafkaBroker" : "localhost:9092"
}
Moving the offsets to the earliest available offset for timestamp
POST localhost:8082/kafka-offset-manager/time-based-offset
POST BODY:
{
"consumerGroupId" : "consumer1",
"topic": "test",
"kafkaBroker" : "localhost:9092",
"timeStampInMillis": "23123123123"
}
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent