mehrere Themennamen mit KafkaListener Anmerkung Mit

Question

Es gibt eine ähnliche Frage ist unten gestellt:

---

Can a single Spring's KafkaConsumer listener listens to multiple topic?

So, jetzt verstehe ich, dass ich ein Array von String an den Themen Parameter der Anmerkung KafkaListener zur Verfügung stellen kann jedoch möchte ich folgendes wissen:

1. wie bekomme ich die Themennamen aus einer Eigenschaften als ein Array von Zeichenketten-Datei?
2. Wie wirkt sich das Lesen mehrerer Themen auf die Offsets aus? Würden die Kunden (Spring Kafka) Offsets pro Thema beibehalten?

Answer 1

Wenn Ihre Immobilie ist my.topics (kommagetrennte) ...

@KafkaListener(id = "foo", topics = "#{'${my.topics}'.split(',')}") 

Ja, Offsets für alle abonnierten Themen/Partitionen verwaltet.