Class BaseRepartitionNode<K,​V>

    • Field Detail

      • keySerde

        protected final org.apache.kafka.common.serialization.Serde<K> keySerde
      • valueSerde

        protected final org.apache.kafka.common.serialization.Serde<V> valueSerde
      • sinkName

        protected final java.lang.String sinkName
      • sourceName

        protected final java.lang.String sourceName
      • repartitionTopic

        protected final java.lang.String repartitionTopic