diff --git a/packages/destination-actions/src/destinations/kafka/send/generated-types.ts b/packages/destination-actions/src/destinations/kafka/send/generated-types.ts index 8a68e951c4..a17e3b3ca8 100644 --- a/packages/destination-actions/src/destinations/kafka/send/generated-types.ts +++ b/packages/destination-actions/src/destinations/kafka/send/generated-types.ts @@ -33,6 +33,10 @@ export interface Payload { * If true, Segment will batch events before sending to Kafka. */ enable_batching?: boolean + /** + * Maximum number of events to include in each batch. Actual batch sizes may be lower. + */ + batch_size?: number /** * The keys to use for batching the events. */ diff --git a/packages/destination-actions/src/destinations/kafka/send/index.ts b/packages/destination-actions/src/destinations/kafka/send/index.ts index 55094ad9d7..71520d72d0 100644 --- a/packages/destination-actions/src/destinations/kafka/send/index.ts +++ b/packages/destination-actions/src/destinations/kafka/send/index.ts @@ -50,6 +50,13 @@ const action: ActionDefinition = { default: true, unsafe_hidden: true }, + batch_size: { + label: 'Batch Size', + description: 'Maximum number of events to include in each batch. Actual batch sizes may be lower.', + type: 'number', + required: false, + default: 1000 + }, batch_keys: { label: 'Batch Keys', description: 'The keys to use for batching the events.',