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.