sink kafka文档描述有误

Métricas do repositório

Stars

6.897 stars (6.897 stars)

Métricas de merge de PR

Mesclagem média 13d 21h (Mesclagem média 13d 21h)143 fundiu PRs em 30d (143 fundiu PRs em 30d)

Description

env {
  parallelism = 1
  job.mode = "STREAMING"
  checkpoint.interval = 10000
}

source {
  MySQL-CDC {
    base-url = "jdbc:mysql://host.docker.internal:3306/data_transfer_source"
    username = "root"
    password = "root"
    table-names = ["data_transfer_source.users"]
    startup.mode = "initial"
  }
}

transform {

}

sink {
 kafka {
      topic = "seatunnel"
      bootstrap.servers = "host.docker.internal:9092"
      format = json
      kafka.request.timeout.ms = 60000
      kafka.config = {
        acks = "all"
        request.timeout.ms = 60000
        buffer.memory = 33554432
      }
  }
}

-

-

Guia do colaborador

Direção de pesquisa

O problema relata que a documentação do sink Kafka afirma incorretamente que não suporta CDC. Localize o arquivo de documentação para o sink Kafka no repositório (provavelmente em 'docs/en/sink/kafka.md' ou similar). Atualize a descrição para indicar que o Kafka suporta CDC. Garanta consistência com outra documentação relacionada. O problema tem um responsável atribuído, então verifique se já há um PR em andamento.

Pilha de tecnologia

javakafka

Domain

backend

Tipo Issue

Documentação

DifficultyDificuldade de implementação estimada para um novo contribuidor, de 1 para alterações muito pequenas a 5 para trabalho de nível especializado.

1

Tempo estimadoUm intervalo de tempo aproximado para um colaborador experiente investigar, implementar, testar e preparar um pull request.

Menos de 1 hora

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

Git

Simpatia para novatosUma pontuação de 1 a 100 que estima o quão acessível este issue é para colaboradores iniciantes.

90