0
respostas

Replication de brokers

Boa noite, Estou com uma duvida como replicamos os brokers, temos 2 ou mais brokers com portas distintas, no nosso codigo estamos colocando o seguinte trecho no consumer e producer:

Producer

    private static Properties properties() {
        Properties properties = new Properties();
        properties.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9092");
        properties.setProperty(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
        properties.setProperty(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, GsonSerializer.class.getName());
        return properties;
    }

Consumer:

   Properties properties(String nameClass, Class<T> type, Map<String, String> overrideProperties) {
        Properties properties = new Properties();
        properties.setProperty(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9092");
        properties.setProperty(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
        properties.setProperty(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, GsonDeserializer.class.getName());
        properties.setProperty(ConsumerConfig.GROUP_ID_CONFIG, nameClass);
        properties.setProperty(ConsumerConfig.CLIENT_ID_CONFIG, nameClass + "-" + UUID.randomUUID().toString());
        properties.setProperty(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, "1");
        properties.setProperty(GsonDeserializer.TYPE_CONFIG, type.getName());
        properties.putAll(overrideProperties);
        return properties;
    }

estamos conectando em uma porta em especifico na 9092, nesse caso seria necessario inserir todas as novas portas do broker, pois os producers estão enviando em tempo de execução , se o 9092, cair no meio ele nao vai conseguir conectar nesse broker em especifico.