sink kafka文档描述有误

Metriche repository

Star

6897 star (6897 star)

Metriche merge PR

Merge medio 13g 21h (Merge medio 13g 21h)143 PR mergiate in 30 g (143 PR mergiate in 30 g)

Descrizione

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
      }
  }
}

-

-

Guida contributor

Direzione di ricerca

Il problema segnala che la documentazione del sink Kafka indica erroneamente che non supporta CDC. Individua il file di documentazione per il sink Kafka nel repository (probabilmente sotto 'docs/en/sink/kafka.md' o simile). Aggiorna la descrizione per indicare che Kafka supporta CDC. Assicurati la coerenza con altra documentazione correlata. Il problema ha un assegnatario, quindi verifica se è già in corso una PR.

Tech stack

javakafka

Dominio

backend

Tipo issue

Documentazione

DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.

1

Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.

Meno di 1 ora

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

Git

Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.

90