How Can One Microservice Consume Multiple Kafka Topics

Axon Framework
,
3

Resulted in an overriden Bean:

@Bean
public StreamableKafkaMessageSource<String, byte[]> streamableKafkaMessageSource(
  ConsumerFactory<String, byte[]> kafkaConsumerFactory,
  Fetcher<String, byte[], KafkaEventMessage> kafkaFetcher) {

return StreamableKafkaMessageSource.<String, byte[]>builder()
    .topics(Arrays.asList(topics))
    .consumerFactory(kafkaConsumerFactory)
    .fetcher(kafkaFetcher)
    .build();

}

Any improvements and optimizations are welcome.