Mit welchem ​​Bereich ist der Verbraucher verbunden?

Question

1. Wie bekomme ich die Partition, an die der Verbraucher angeschlossen ist?
2. Wenn es mehrere Themen subskribiert ist, wie erhalten Metriken (eingehende-Byte-Rate) für verschiedene Themen aus consumer.metrics()?

Answer 1

1. Wenn Sie Teil einer Verbrauchergruppe und die Nutzung auf dem Auto Partitionen Zuordnung sind, werden alle Zeitpartitionen zugewiesen (aufgrund einer Neuverteilung), die onPartitionsAssigned() (der ConsumerRebalanceListener) mit der angerufene Sammlung der zugewiesenen Partitionen. BTW in jedem Moment können Sie die assignment() -Methode aufrufen, um die zugewiesenen Partitionen zu erhalten.
2. nicht ganz sicher, aber ja, sollte die Methode metrics() die Arbeit machen.