InternalFixedKeyRecordFactory (streams 8.1.1-ce API)

java.lang.Object

org.apache.kafka.streams.processor.api.InternalFixedKeyRecordFactory

public final class InternalFixedKeyRecordFactoryextends Object

Method Summary
Modifier and Type
Method
Description
static <KIn,VIn> FixedKeyRecord<KIn,VIn>
create(Record<KIn,VIn> record)
Only allowed way to create FixedKeyRecords.
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- create
  public static <KIn,VIn> FixedKeyRecord<KIn,VIn> create(Record<KIn,VIn> record)
  Only allowed way to create FixedKeyRecords.
  DO NOT USE THIS FACTORY OUTSIDE THE FRAMEWORK. This could produce undesired results by not partitioning record properly.
  See Also:
  FixedKeyProcessor