apache/pulsar

Kafka Sink Connector: support non-String keys

Offen

#9.848 geöffnet am 09.03.2021

Auf GitHub ansehenContributor Guide
 (4 Kommentare) (0 Reaktionen) (0 zugewiesene Personen)Java (3.485 Forks)batch import
good first issuehelp wantedtype/enhancement

Repository-Metriken

Stars
 (13.697 Sterne)
PR-Merge-Metriken
 (Durchschn. Merge 3T 10h) (146 gemergte PRs in 30 T)

Beschreibung

Currently the Kafka Sink Connector is able to support only keys with a String value.

We should support the generic byte[] key, as it is in Kafka. Also we should support other data types and possibly may the generic key/value pair of Kafka to a KeyValue Pulsar schema

Contributor Guide

Research-Richtung
Untersuchen Sie die aktuelle Implementierung des Kafka Sink Connectors für die Schlüsselverarbeitung, verstehen Sie die Schema Registry und Serialisierungsmechanismen sowohl in Kafka als auch in Pulsar, und schlagen Sie eine Lösung vor, um Nicht String Schlüssel (z.B. byte[] oder andere Typen) mit geeigneten Schema Konvertierungen zu unterstützen.
Tech Stack
java
Domain
backend
Issue Type
Funktion
SchwierigkeitGeschätzte Implementierungsschwierigkeit für neue Contributors, von 1 für sehr kleine Änderungen bis 5 für Expertenarbeit.
3
Geschätzte ZeitEin grober Zeitrahmen, um zu recherchieren, zu implementieren, zu testen und einen Pull Request vorzubereiten.
Halber Tag
AktivitätsstatusWie verfügbar das Issue gerade wirkt: frisch, aktiv, stale, blockiert oder wartet auf Maintainer-Input.
Aktiv
KlarheitWie klar das Issue die erwartete Änderung, Akzeptanzkriterien und den nächsten Schritt erklärt.
Klar
Voraussetzungen
JavaKafkaPulsar
EinsteigerfreundlichkeitEin Score von 1 bis 100, der schätzt, wie zugänglich dieses Issue für First-Time Contributors ist.
40