sink kafka文档描述有误

Métriques du dépôt

Stars

6 897 stars (6 897 stars)

Métriques de merge PR

Merge moyen 13j 21h (Merge moyen 13j 21h)143 PRs mergées en 30 j (143 PRs mergées en 30 j)

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

-

-

Guide contributeur

Direction de recherche

Le problème signale que la documentation du sink Kafka indique à tort qu'il ne prend pas en charge CDC. Localisez le fichier de documentation pour le sink Kafka dans le dépôt (probablement sous 'docs/en/sink/kafka.md' ou similaire). Mettez à jour la description pour indiquer que Kafka prend en charge CDC. Assurez vous de la cohérence avec les autres documentations connexes. Le problème a un assigné, donc vérifiez si une PR est déjà en cours.

Stack technique

javakafka

Domaine

backend

Type d'issue

Documentation

DifficultéDifficulté estimée pour un nouveau contributeur, de 1 pour un très petit changement à 5 pour un travail expert.

1

Temps estiméFourchette de temps approximative pour investiguer, implémenter, tester et préparer une pull request.

Moins d'une heure

Statut d'activitéDisponibilité apparente de l'issue : fraîche, active, ancienne, bloquée ou en attente d'un mainteneur.

Active

ClartéClarté avec laquelle l'issue explique le changement attendu, les critères d'acceptation et la prochaine étape.

Claire

Prérequis

Git

Accessibilité débutantScore de 1 à 100 estimant l'accessibilité de cette issue pour un premier contributeur.

90