我有一个Kafka流应用程序和Avro模式的每一个主题，也为关键。关键主题模式是相同的。
现在，有一个KafkaStream（KStream）对象，它以已知的key对象作为key，还有一个value对象（从AvroSchema派生），它扩展了org.apache.avro.specific.SpecificRecordBase，但它可以是我的主题内容的任何avro模式。
KStream<CustomKey, ? extends SpecificRecordBase> myStream = ...
我想要实现的是在这个流上运行min和max函数。问题是我不知道?对象是什么，并且由于有30多个（将来还会增加）主题，我不想做开关用例。所以我有以下内容：

public KStream<CustomKey, ? extends SpecificRecordBase> max(
    final KStream<CustomKey, ? extends SpecificRecordBase> myStream,
    final String attributeName) {

    SpecificRecordBase maxValue = ...;
    myStream.foreach((key, value) -> {
      value.get(attributeName) // I want to find the max value for this attribute, 
                               // but at this point we don't know it's type and
                               // and we can't assign maxValue = value, because this is a lambda 
                               // function.
    });

    // find and return the max value
  }

我的问题是，如何计算myStream在attributeName属性上的最大值？