Как мы можем слушать несколько тем в одном и том же потребителе Kafka?

Question

Я хочу иметь несколько тем в одной и той же потребительской конфигурации kafka.
Я попробовал следующие варианты, но это не сработало.

С
ContainerProperties containerProps = new ContainerProperties(gatewayPropertyConfigurer.getProperty("topic","topic1);

создано отдельное containerproperty для topic1.

Пожалуйста, дайте мне знать, если у вас есть какие-либо предложения.

Answer 1

Я не знаю, какой фреймворк вы используете, но базовый KafkaConsumer Java-класс имеет subscribe метод, который вы должны изучить.

Вам нужны разные свойства для разных потребителей, только если у вас действительно разные свойства.Например, если с настройками по умолчанию все в порядке и обе темы имеют одинаковые параметры сериализации, вам нужен только один набор свойств.