apache/pulsar

Kafka Sink Connector: support non-String keys

Aperta

#9848 aperta il 9 mar 2021

Vedi su GitHubGuida contributor
 (4 commenti) (0 reazioni) (0 assegnatari)Java (3485 fork)batch import
good first issuehelp wantedtype/enhancement

Metriche repository

Star
 (13.697 stelle)
Metriche merge PR
 (Merge medio 3g 10h) (146 PR mergiate in 30 g)

Descrizione

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

Guida contributor

Direzione di ricerca
Analizza l'implementazione attuale del Kafka Sink Connector per la gestione delle chiavi, comprendi il schema registry e i meccanismi di serializzazione sia in Kafka che in Pulsar, e proponi una soluzione per supportare chiavi non stringa (ad esempio byte[] o altri tipi) utilizzando conversioni di schema appropriate.
Tech stack
java
Dominio
backend
Tipo issue
Funzionalità
DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.
3
Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.
Mezza giornata
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
Attiva
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
Chiara
Prerequisiti
JavaKafkaPulsar
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
40