KafkaPilot - Bir Apache Kafka masaüstü istemcisi geliştirdim.
(github.com/pjhun0412)Merhaba.
Son birkaç ay içinde, kendi kullanımım için KafkaPilot adlı bir Apache Kafka masaüstü istemcisi geliştirdim.
Kafka kullanırken, topic’leri görüntülemekten çok sonrasındaki işleri daha sık yapıyoruz; ancak mevcut araçlarda çoğu zaman birden fazla program arasında geçiş yapmak ya da doğrudan script yazmak gerekiyor.
Örneğin:
Belirli bir mesajı başka bir cluster’a yeniden gönderme (Replay)
Consumer Group Offset değiştirme
Test verisini tekrar tekrar üretme
Gerçek zamanlı konum verisi izleme
Bunlar gibi işler.
Bu yüzden bu işlevleri tek bir yerel masaüstü uygulamasında kullanabilmek için böyle bir araç geliştirdim.
Başlıca özellikler
- Split Pane ile iki topic’i aynı anda görüntüleme ve karşılaştırma
- Offset / Time / Live modlarıyla mesaj görüntüleme
- Görüntülenen mesajları başka bir topic’e veya başka bir Kafka Cluster’ına Replay etme
${uuid},${seq},${date}gibi Dynamic Template’ler kullanarak test verisi üretme- Consumer Group görüntüleme ve güvenli Offset Reset
- Schema Registry tabanlı Avro desteği
- İki topic’i aynı anda karşılaştırabilen Split Pane
- Gerçek zamanlı Produce ve Interval Produce
- Koordinat verileri için Map Viewer
Özellikle Map Viewer, smart city, BIS ve C-ITS projeleri yürütürken ihtiyaç duyduğum için eklediğim bir özellik oldu.
Kafka’ya gelen konum verilerini doğrudan harita üzerinde görebiliyorsunuz.
WGS84
Korea TM(EPSG:5186)
UTM
Koordinat sistemlerini destekliyor; ayrıca araç hareket izi, Heading ve Follow Mode gibi özellikler sunuyor.
Tüm işlevler, ayrı bir sunucu olmadan yerel masaüstü uygulamasında çalışır.
Şu anda MIT lisansı ile yayımlandı; Kafka kullananların geri bildirimlerini ve iyileştirme önerilerini memnuniyetle karşılıyorum.
GitHub
https://github.com/pjhun0412/KafkaPilot
Dokümantasyon
https://github.com/pjhun0412/KafkaPilot/blob/main/README.ko.md
Kullanıp denedikten sonra sizi rahatsız eden noktalar ya da eklenmesini istediğiniz özellikler olursa, lütfen özgürce görüş paylaşın.
Henüz yorum yok.