Protocol

Kafka Event Collector defines a schema for events published. Schema is defined with Protocol Buffers format.

Topic

Default value: "__collector"

Configuration:

• Compaction enabled.

Kafka Record

Key/Value Record is defined as following:

Headers

Key: entity_type

This Header is used for Users to filter the type of entity they are interested about.

Serialized as: String

Format: "${entityType}"

Example: "TOPIC"

Key

Serialized as: String

Format: "${entityType}-${entityId}"

Example: TOPIC-customer_events

Value

Serialized as: Byte Array

Format: Protobuf message