Kafka Connect
Kafka Connect connectorlarını yönetin: durum, hata yığını, görevler, offsetler ve eklentiler; onaylı oluşturma, yamalama, duraklatma/sürdürme; yeniden başlatma ve silme yıkıcı.
Açıklama
Apache Kafka Connect REST API entegrasyonu (Apache Kafka ve Confluent Platform Connect worker'ları). - **Okuma:** worker sürümü ve sağlığı, logger seviyeleri, kurulu connector/dönüştürücü/SMT eklentileri ve yapılandırma tanımları, connector listesi (durum/bilgi genişletmeli), connector ayrıntısı ve yapılandırması, connector ve görev durumu (hata yığınıyla), aktif topicler, görevler, offsetler. - **Aksiyon (onaylı):** connector oluşturma, çerçeve anahtarlarıyla yapılandırma yamalama (PATCH), duraklatma, sürdürme, durdurma, aktif topic kaydını sıfırlama, offset değiştirme, logger seviyesini değiştirme. - **Yıkıcı:** connector ve görev yeniden başlatma, connector silme, offset sıfırlama. Connector yapılandırması sır içerebilir: yapılandırma döndüren okuma araçları notlarında uyarır, oluşturma gövdesindeki `config` maskelenir; sırların ConfigProvider (`${file:...}`) ile dışarı alınması önerilir. Değişken anahtarlı düz gövde isteyen tam yapılandırma yazma (`PUT .../config`) ve doğrulama (`.../config/validate`) uçları motor sınırı nedeniyle yoktur. ## Kaynak - API belgesi: https://kafka.apache.org/41/kafka-connect/user-guide/ ve https://kafka.apache.org/41/generated/connect_rest.yaml (Kafka Connect REST API, Kafka 3.5–4.1); https://docs.confluent.io/platform/current/connect/references/restapi.html - Kimlik: static Basic — Connect worker'ında BasicAuthSecurityRestExtension (JAAS PropertyFileLoginModule) ile tanımlı kullanıcı ve parola; kimliksiz kurulumlarda başlık yok sayılır - Doğrulanmadı: gövdesiz PUT/POST (pause, resume, stop, topics/reset, restart) isteklerinde gönderilen `{}` gövdenin kabulü; Basic uzantısının `/` ve `/health` uçlarını da koruması; `admin.listeners` ayrıyken logger uçlarının ana adreste bulunmaması; PATCH config (3.8+), `scope=cluster` (3.7+), `/health` (3.9+) ve eklenti `version` sorgusunun (4.0+) kurulu sürümde bulunması; `expand` parametresinin Apache Kafka'da da çalışması; görev yapılandırmalarında sırların çözülmüş döndüğü durumlar; self-signed sertifika - Logo: https://kafka.apache.org/logos/kafka-logo-no-text.png (Apache Kafka resmi logo dizini)
Bu sürümdeki tool'lar
| Tool | Tür | Klasör |
|---|---|---|
kafka_connect_worker_bilgisi |
okuma | Worker |
kafka_connect_worker_sagligi |
okuma | Worker |
kafka_connect_logger_listele |
okuma | Worker/Loglama |
kafka_connect_logger_getir |
okuma | Worker/Loglama |
kafka_connect_logger_seviyesi_ayarla |
aksiyon | Worker/Loglama |
kafka_connect_eklenti_listele |
okuma | Eklentiler |
kafka_connect_eklenti_yapilandirma_tanimi |
okuma | Eklentiler |
kafka_connect_connector_listele |
okuma | Connectorlar |
kafka_connect_connector_durumu |
okuma | Connectorlar |
kafka_connect_connector_topicleri |
okuma | Connectorlar |
kafka_connect_connector_olustur |
aksiyon | Connectorlar |
kafka_connect_connector_yapilandirma_yamala |
aksiyon | Connectorlar |
kafka_connect_connector_duraklat |
aksiyon | Connectorlar |
kafka_connect_connector_surdur |
aksiyon | Connectorlar |
kafka_connect_connector_durdur |
aksiyon | Connectorlar |
kafka_connect_connector_yeniden_baslat |
aksiyon | Connectorlar |
kafka_connect_connector_sil |
aksiyon | Connectorlar |
kafka_connect_connector_topiclerini_sifirla |
aksiyon | Connectorlar |
kafka_connect_gorev_durumu |
okuma | Connectorlar/Görevler |
kafka_connect_gorev_yeniden_baslat |
aksiyon | Connectorlar/Görevler |
kafka_connect_offset_getir |
okuma | Connectorlar/Offsetler |
kafka_connect_offset_degistir |
aksiyon | Connectorlar/Offsetler |
kafka_connect_offset_sifirla |
aksiyon | Connectorlar/Offsetler |
Sürümler
| Sürüm | Durum | Yayın | Tool | Değişiklikler |
|---|---|---|---|---|
| v0.1.0 | yayında | 20.10.2026 | 23 | İlk sürüm. |
Nasıl kurulur
Kendi Gateclave panelinizde Marketplace ekranını açın ve bu ürünün manifestini içe aktarın. Kurulum iki adımdır: bağlantı bilgisi (hedef + Vault'tan seçilen kimlik), ardından bağlanacak tool'ların seçimi. Yeni sürüm çıktığında Yükselt ile geçersiniz — bağlayıcılarınız, kimlik referanslarınız ve tool seçiminiz korunur.