Spring Bookt Kafka ABSwitchCluster

Viewed 125

I couldn't find any example to swtich between kafka cluster .

Anyone has implmeneted this class ABSwitchCluster from Spring Kafka.

https://docs.spring.io/spring-kafka/reference/html/

I tried with below code, but its not switching cluster.

@RestController
public class ApacheKafkaWebController {

    @Autowired
    ConsumerKakfaConfiguration configuration;

    @Autowired
    private KafkaListenerEndpointRegistry registry;

    @Autowired
    private ABSwitchCluster switcher;

    @GetMapping(value = "/switch")
    public String producer() {

        registry.stop();
        switcher.secondary();
        registry.start();
        return "switched!";
    }

}

and swticher bean here:

 @Bean
    public ABSwitchCluster switcher() {
        return new ABSwitchCluster("127.0.0.1:9095", "127.0.0.1:9096");
    }

Could you please tell me am I missing anything here?, still its running in 9095 port.

1 Answers

See this answer and this test.

Basically, you switch the cluster and reset the connections by stopping and starting listener containers and resetting the producer factory.

Related