apache/pulsar

Kafka Sink Connector: support non-String keys

Open

#9.848 aberto em 9 de mar. de 2021

Ver no GitHub
 (4 comments) (0 reactions) (0 assignees)Java (3.485 forks)batch import
good first issuehelp wantedtype/enhancement

Métricas do repositório

Stars
 (13.697 stars)
Métricas de merge de PR
 (Mesclagem média 3d 10h) (146 fundiu PRs em 30d)

Description

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

Guia do colaborador

Direção de pesquisa
Investigue a implementação atual do Kafka Sink Connector para manipulação de chaves, entenda o schema registry e os mecanismos de serialização no Kafka e no Pulsar, e proponha uma solução para suportar chaves não string (por exemplo, byte[] ou outros tipos) usando conversões de schema apropriadas.
Pilha de tecnologia
java
Domain
backend
Tipo Issue
Funcionalidade
DifficultyDificuldade de implementação estimada para um novo contribuidor, de 1 para alterações muito pequenas a 5 para trabalho de nível especializado.
3
Tempo estimadoUm intervalo de tempo aproximado para um colaborador experiente investigar, implementar, testar e preparar um pull request.
Meio dia
Status da atividadeQuão disponível o issue aparece agora: novo, ativo, obsoleto, bloqueado ou aguardando entrada do mantenedor.
Ativo
ClarityCom que clareza o issue explica a mudança esperada, os critérios de aceitação e a próxima etapa.
Claro
Prerequisites
JavaKafkaPulsar
Simpatia para novatosUma pontuação de 1 a 100 que estima o quão acessível este issue é para colaboradores iniciantes.
40