Module io.cloudevents.kafka

Package io.cloudevents.kafka

Class PartitionKeyExtensionInterceptor

java.lang.Object

io.cloudevents.kafka.PartitionKeyExtensionInterceptor

All Implemented Interfaces:

AutoCloseable, ProducerInterceptor<Object,io.cloudevents.CloudEvent>, Configurable

public class PartitionKeyExtensionInterceptor
extends Object
implements ProducerInterceptor<Object,io.cloudevents.CloudEvent>

This ProducerInterceptor implements the partitioning extension, as described in the CloudEvents Kafka specification.

When using in your KafkaProducer, it will pick the partitionkey extension from the event and will set it as record key. If the extension is missing, It won't replace the key from the original record.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PARTITION_KEY_EXTENSION	The extension key of partition key extension.

Constructor Summary

Constructors

Constructor	Description
PartitionKeyExtensionInterceptor()

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(Map<String,?> configs)
void	onAcknowledgement(RecordMetadata metadata, Exception exception)
ProducerRecord<Object,io.cloudevents.CloudEvent>	onSend(ProducerRecord<Object,io.cloudevents.CloudEvent> record)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.kafka.clients.producer.ProducerInterceptor

onAcknowledgement

Field Details

PARTITION_KEY_EXTENSION

public static final String PARTITION_KEY_EXTENSION

The extension key of partition key extension.

See Also:

• Constant Field Values

Constructor Details

PartitionKeyExtensionInterceptor

public PartitionKeyExtensionInterceptor()

Method Details

onSend

public ProducerRecord<Object,io.cloudevents.CloudEvent> onSend(ProducerRecord<Object,io.cloudevents.CloudEvent> record)

Specified by:

onSend in interface ProducerInterceptor<Object,io.cloudevents.CloudEvent>

onAcknowledgement

public void onAcknowledgement(RecordMetadata metadata,
 Exception exception)

Specified by:

onAcknowledgement in interface ProducerInterceptor<Object,io.cloudevents.CloudEvent>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ProducerInterceptor<Object,io.cloudevents.CloudEvent>

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface Configurable