Comment changer les répliques du sujet kafka?

Après un Kafka sujet créé par le producteur ou l'administrateur, comment changer le nombre de répliques de ce sujet?(augmenter ou diminuer les répliques de la numéro.)

source d'informationauteur GuruPo | 2016-06-22

  1. 5

    Edit: j'ai été prouvé d'être mal - s'il vous plaît vérifier l'excellente réponse de lukdumi.

    Je pars de ma réponse originale à cette question par souci d'exhaustivité pour l'instant.

    Je ne pense pas que vous le pouvez. Normalement, ce serait quelque chose comme

    ./kafka-topics.sh --zookeeper localhost:2181-modifier --sujet test2
    --réplication-3 facteur de

    mais il dit

    Option "[réplication-factor]" ne peut pas être utilisé avec l'option"[modifier]"

    C'est drôle que vous pouvez changer le nombre de partitions à la volée (ce qui est souvent extrêmement destructeur d'action lorsqu'il est effectué dans l'exécution), mais ne peut pas augmenter facteur de réplication, ce qui devrait être transparent. Mais rappelez-vous, c'est de 0,10, pas 10.0... Veuillez voir ici pour une demande d'amélioration https://issues.apache.org/jira/browse/KAFKA-1543

  2. 51

    Pour augmenter le nombre de répliques pour un sujet donné, vous devez:

    1. Spécifiez le supplément de réplicas dans un personnalisé réaffectation fichier json

    Par exemple, vous pouvez créer augmentation de la réplication-facteur.json et de mettre ce contenu dans:

    {"version":1,
  "partitions":[
     {"topic":"signals","partition":0,"replicas":[0,1,2]},
     {"topic":"signals","partition":1,"replicas":[0,1,2]},
     {"topic":"signals","partition":2,"replicas":[0,1,2]}
]}

    2. Utiliser le fichier avec l'option --exécuter l'option de la kafka-réaffecter-partitions outil

    [ou kafka-reassign-partitions.sh - en fonction de la kafka package]

    Par exemple:

    $ kafka-reassign-partitions --zookeeper localhost:2181 --reassignment-json-file increase-replication-factor.json --execute

    3. Vérifier le facteur de réplication avec le kafka-sujets outil

    [ou kafka-topics.sh - en fonction de la kafka package]

     $ kafka-topics --zookeeper localhost:2181 --topic signals --describe

Topic:signals   PartitionCount:3    ReplicationFactor:3 Configs:retention.ms=1000000000
Topic: signals  Partition: 0    Leader: 2   Replicas: 0,1,2 Isr: 2,0,1
Topic: signals  Partition: 1    Leader: 2   Replicas: 0,1,2 Isr: 2,0,1
Topic: signals  Partition: 2    Leader: 2   Replicas: 0,1,2 Isr: 2,0,1

    Voir aussi: la partie de la documentation officielle qui décrit comment
    pour augmenter le facteur de réplication    .