Package org.apache.kafka.streams.processor.api

Class InternalFixedKeyRecordFactory

java.lang.Object

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

public final class InternalFixedKeyRecordFactory
extends 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

clone, equals, finalize, 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