İçeriğe geç
MCB

11 · Developer Tools

Kafka Olay İnceleme Aracı

Bir Kafka topic’inden belirli zaman aralığındaki mesajları çekip dosyaya döken, sorun analizi için küçük bir araç.

Tüm projeler
  • Tamamlandı
  • Kafka
  • Debugging
  • Tooling
İstekKuyrukİşçiServisSonuçthroughput ▸ rate limit · retry · dedupTasarım görseli · ekran görüntüsü değil

Project Overview

Bir olay anında “o saatlerde topic’e ne yazıldı?” sorusunu hızlı yanıtlamak için yazılan yardımcı betik.

The Challenge

Belirli bir saat aralığındaki mesajları, tüketici grubunu etkilemeden incelemek.

The Solution

Zaman damgasına göre offset bulup yalnızca o aralığı okuyan, ofset commit etmeyen tüketici.

How It Works

  1. 01Başlangıç ve bitiş zamanı milisaniye zaman damgasına çevrilir.
  2. 02Her partition için bu zamana denk gelen offset’ler bulunur.
  3. 03Tüketici otomatik commit olmadan o aralıktaki mesajları okur.
  4. 04Mesajlar zaman damgasıyla birlikte çıktı dosyasına yazılır; analiz bu dosyadan yapılır.

Key Features

  • Zaman aralığına göre okuma
  • Commit etmeden güvenli tüketim
  • Dosyaya döküm

Architecture

Tek betik; Kafka tüketici API’si ile partition bazlı offset arama.

Technologies & Tools

  • Python
  • kafka-python

Screenshots

Gerçek uygulama ekran görüntüleri eklenecek. Yukarıdaki kapak yalnızca tasarım görselidir.

Results

Ölçülebilir sonuçlar doğrulandıkça eklenecek.

Links

GitHub bağlantısı yokCanlı demo yok
Sıradaki projeMakro Muhasebe Pro

Let's build something great

Bir fikriniz mi var?

Yeni projeler, teknoloji, iş birlikleri ve yaratıcı fikirler üzerine konuşalım.

Benimle İletişime Geç