Skip to content

sys-sp-create-event-stream-group-transact-sql.md

Latest commit

 

History

History
148 lines (103 loc) · 6.23 KB

sys-sp-create-event-stream-group-transact-sql.md

File metadata and controls

148 lines (103 loc) · 6.23 KB
Raw
title sys.sp_create_event_stream_group (Transact-SQL)
description sys.sp_create_event_stream_group creates an event stream group for the change event streaming feature.
author nzagorac-ms
ms.author nzagorac
ms.reviewer mathoma,randolphwest
ms.date 06/19/2026
ms.service sql
ms.subservice system-objects
ms.topic reference
ms.custom
ignite-2025
ai-usage ai-assisted
f1_keywords
sys_sp_create_event_stream_group_TSQL
sys_sp_create_event_stream_group
helpviewer_keywords
sys_sp_create_event_stream_group
dev_langs
TSQL
monikerRange =sql-server-ver17 || =sql-server-linux-ver17

sys.sp_create_event_stream_group (Transact-SQL)

[!INCLUDE sqlserver2025]

Creates an event group stream for the change event streaming (CES) feature introduced in [!INCLUDE sssql25-md].

[!INCLUDE change-event-streaming-preview]

:::image type="icon" source="../../includes/media/topic-link-icon.svg" border="false"::: Transact-SQL syntax conventions

Syntax

sys.sp_create_event_stream_group
    [ @stream_group_name = ] N'stream_group_name'
    , [ @destination_type = ] N'destination_type'
    , [ @destination_location = ] N'destination_location'
    , [ @destination_credential = ] N'destination_credential'
    [ , [ @max_message_size_kb = ] max_message_size_kb ]
    [ , [ @partition_key_scheme = ] N'partition_key_scheme' ]
    [ , [ @partition_key_column_name = ] N'partition_key_column_name' ]
    [ , [ @encoding = ] N'encoding' ]
[ ; ]

Arguments

[ @stream_group_name = ] N'stream_group_name'

Specifies the name of the event stream group you want to create. @stream_group_name is sysname, with no default, and can't be NULL.

[ @destination_type = ] N'destination_type'

Specifies the streaming destination type. @destination_type is sysname, with no default, and can't be NULL.

@destination_type can be one of the following values:

  • AzureEventHubsAmqp
  • AzureEventHubsApacheKafka

[ @destination_location = ] N'destination_location'

Describes the Azure Event Hubs namespace and instance name. @destination_location is nvarchar(4000), with no default, and can't be NULL.

For the Apache Kafka protocol, specify the port.

[ @destination_credential = ] N'destination_credential'

Specifies database scoped credential name to be used. @destination_credential is sysname, with no default, and can't be NULL.

[ @max_message_size_kb = ] max_message_size_kb

If specified, defines the max CES message size in kilobytes. @max_message_size_kb is int, and can't be NULL. The message is split if it exceeds the specified max size. This parameter is optional.

@max_message_size_kb has the following characteristics:

Value Description
128 (minimum) Corresponds to 128 KB
256 (default) Corresponds to 256 KB
1024 (maximum) Corresponds to 1 MB

The @max_message_size_kb parameter should align to the limits of the destination. For example, the maximum message size for Azure Event Hubs is 1 MB for the Standard and Premium tiers. For more information, see Azure Event Hubs quotas.

[ @partition_key_scheme = ] N'partition_key_scheme'

Defines the type of partitioning. @partition_key_scheme is sysname, and can't be NULL.

@partition_key_scheme can be one of the following values:

Value Description
None (default) Partitioning isn't specified, so events are assigned to partitions by the event hub using a round-robin strategy.
StreamGroup Partitioning is done by stream group so that all tables in the stream group are streamed to the same partition.
Table Partitioning is done by table so that events from the same table in the stream group are guaranteed to be sent to the same partition. The partitioning key is the internal table identifier.
Column Partitioning is done by the value of the column specified by the partition_key_column_name parameter. Events are assigned to partitions based on that column's value in the row for which the event is published.

[ @partition_key_column_name = ] N'partition_key_column_name'

Defines which column to use for partitioning when @partition_key_scheme is set to Column. @partition_key_column_name is sysname, and can't be NULL.

Use a two-part name for the column that includes both the schema name and column name. For example, a valid value is dbo.Addresses.

[ @encoding = ] N'encoding'

Specifies the message encoding. @encoding is sysname, and can't be NULL.

@encoding can be one of the following values:

  • JSON (default)
  • Binary

Return code values

0 (success) or 1 (failure).

Permissions

A user with CONTROL database permissions, db_owner database role membership, or sysadmin server role membership can execute this procedure.

Examples

A. Create event stream group that streams into Azure Event Hubs with AMQP protocol

EXECUTE sys.sp_create_event_stream_group
    @stream_group_name = N'myStreamGroup',
    @destination_type = N'AzureEventHubsAmqp',
    @destination_location = N'myEventHubsNamespace.servicebus.windows.net/myEventHubsInstance',
    @destination_credential = MyDatabaseScopedCredentialForCes;

B. Create event stream group that streams into Azure Event Hubs with Kafka protocol

EXECUTE sys.sp_create_event_stream_group
    @stream_group_name = N'myStreamGroup',
    @destination_type = N'AzureEventHubsAmqp',
    @destination_location = N'myEventHubsNamespace.servicebus.windows.net:9093/myEventHubsInstance',
    @destination_credential = MyDatabaseScopedCredentialForCes;

Related content