Class RepartitionedInternal<K,​V>


  • public class RepartitionedInternal<K,​V>
    extends Repartitioned<K,​V>
    • Constructor Detail

      • RepartitionedInternal

        public RepartitionedInternal​(Repartitioned<K,​V> repartitioned)
    • Method Detail

      • name

        public java.lang.String name()
      • keySerde

        public org.apache.kafka.common.serialization.Serde<K> keySerde()
      • valueSerde

        public org.apache.kafka.common.serialization.Serde<V> valueSerde()
      • numberOfPartitions

        public java.lang.Integer numberOfPartitions()