server: port: 0 spring: kafka: bootstrap-servers: - {Kafka 서버 IP 주소}:9092 - {Kafka 서버 IP 주소}:19092 - {Kafka 서버 IP 주소}:29092 consumer: key-deserializer: org.apache.kafka.common.serialization.StringDeserializer value-deserializer: org.apache.kafka.common.serialization.StringDeserializer auto-offset-reset: earliest
server: port: 0 spring: kafka: bootstrap-servers: - {Kafka 서버 IP 주소}:9092 - {Kafka 서버 IP 주소}:19092 - {Kafka 서버 IP 주소}:29092 consumer: key-deserializer: org.apache.kafka.common.serialization.StringDeserializer value-deserializer: org.apache.kafka.common.serialization.StringDeserializer auto-offset-reset: earliest
위와 같이 코드를 작성해야 여러 Kafka 서버 중 일부 서버가 중단되도 정상적으로 Kafka를 활용할 수 있다.