Features:
- Two deserializers are supported: StringDeserializer and KafkaAvroDeserializer
- Records displayed have keys, headers and values that are pretty printed JSON strings.
- Each record has counter at the beginning that ease to see how many records were fetched.
- App supports from 1 to 5 parallel consumers.
- If group rebalancing has started there is a mechanism that avoids records' duplicates.
- Each time app starts new consumer group id is created.
- If "Seek to end" checkbox is disabled consumers will fetch from beginning of all partitions and vice versa.
- If "Is topic Avro?" checkbox is enabled then you must provide Schema Registry IP and data from Avro topic will be fetched.
- It is possible to select the whole record by clicking on each element or you may use buttons "Select All" , "Deselect All" to select/deselect all records. To copy elements you should right click of the mouse button and select "Copy".
- You may open debug kafka logs with the corresponding "Open Logs" button. File with logs is stored in user temp folder and is named kafka-debug.log. File will be opened automatically in the default app for this type of file - .log
- "Clear" button will only clear the records pane without disrupting consumption.
- It is highly advisable to first stop consumer group prior to closing the app.
Avro consumption in progress, one record selected for copying:
Regular topic consumption was stopped:
