src/main/java/com/google/cloud/run/kafkascaler/Scaler.java (1 line): - line 125: // TODO: Make this more polymorphic.