Tudo bom ? Tentei duplicar os clusteres mas nao esta dando certo. Coloquei o
default.replication.factor = 2
nos 2 server.properties [ caso, server2.properties] e tb subi os 2 clusteres do kafka.
Se dou o comando
.\bin\windows\kafka-topics.bat --bootstrap-server localhost:9092 --describe
recebo a saida:
Topic:ECOMMERCE_ORDER_REJECT PartitionCount:4 ReplicationFactor:1 Configs:segment.bytes=1073741824
Topic: ECOMMERCE_ORDER_REJECT Partition: 0 Leader: 0 Replicas: 0 Isr: 0
Se dou o
.\bin\windows\kafka-consumer-groups.bat --all-groups --bootstrap-server localhost:9093 --describe
Recebo:
GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
FraudDetectorService ECOMMERCE_NEW_ORDER 0 14 14 0 099f8e91-9ac1-46ba-9c96-f3b857d07cf8-5c8539e6-5502-4fd4-8bfe-419
Se dou o:
.\bin\windows\kafka-consumer-groups.bat --all-groups --bootstrap-server localhost:9092 --describe
Recebo:
GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
FraudDetectorService ECOMMERCE_NEW_ORDER 0 14 14 0 099f8e91-9ac1-46ba-9c96-f3b857d07cf8-5c8539e6-5502-4fd4-8bfe-419
Pelo que entendi, ele esta se comunicando com o segundo cluster, que esta na porta 9093, mas nao esta usando ele como replica.