diff --git a/.generator/schemas/v2/openapi.yaml b/.generator/schemas/v2/openapi.yaml index d2192b7484..f81d82c0f2 100644 --- a/.generator/schemas/v2/openapi.yaml +++ b/.generator/schemas/v2/openapi.yaml @@ -35455,6 +35455,37 @@ components: role session. type: string type: object + ObservabilityPipelineCloudPremDestination: + description: The `cloud_prem` destination sends logs to Datadog CloudPrem. + properties: + id: + description: The unique identifier for this component. + example: cloud-prem-destination + type: string + inputs: + description: A list of component IDs whose output is used as the `input` + for this component. + example: + - filter-processor + items: + type: string + type: array + type: + $ref: '#/components/schemas/ObservabilityPipelineCloudPremDestinationType' + required: + - id + - type + - inputs + type: object + ObservabilityPipelineCloudPremDestinationType: + default: cloud_prem + description: The destination type. The value should always be `cloud_prem`. + enum: + - cloud_prem + example: cloud_prem + type: string + x-enum-varnames: + - CLOUD_PREM ObservabilityPipelineComponentDisplayName: description: The display name for a component. example: my component @@ -35510,6 +35541,7 @@ components: description: A destination for the pipeline. oneOf: - $ref: '#/components/schemas/ObservabilityPipelineDatadogLogsDestination' + - $ref: '#/components/schemas/ObservabilityPipelineCloudPremDestination' - $ref: '#/components/schemas/ObservabilityPipelineAmazonS3Destination' - $ref: '#/components/schemas/ObservabilityPipelineGoogleCloudStorageDestination' - $ref: '#/components/schemas/ObservabilityPipelineSplunkHecDestination' @@ -35528,6 +35560,7 @@ components: - $ref: '#/components/schemas/ObservabilityPipelineAmazonSecurityLakeDestination' - $ref: '#/components/schemas/ObservabilityPipelineCrowdStrikeNextGenSiemDestination' - $ref: '#/components/schemas/ObservabilityPipelineGooglePubSubDestination' + - $ref: '#/components/schemas/ObservabilityPipelineKafkaDestination' ObservabilityPipelineConfigProcessorGroup: description: A group of processors. example: @@ -36826,6 +36859,151 @@ components: type: string x-enum-varnames: - HTTP_SERVER + ObservabilityPipelineKafkaDestination: + description: The `kafka` destination sends logs to Apache Kafka topics. + properties: + compression: + $ref: '#/components/schemas/ObservabilityPipelineKafkaDestinationCompression' + encoding: + $ref: '#/components/schemas/ObservabilityPipelineKafkaDestinationEncoding' + headers_key: + description: The field name to use for Kafka message headers. + example: headers + type: string + id: + description: The unique identifier for this component. + example: kafka-destination + type: string + inputs: + description: A list of component IDs whose output is used as the `input` + for this component. + example: + - filter-processor + items: + type: string + type: array + key_field: + description: The field name to use as the Kafka message key. + example: message_id + type: string + librdkafka_options: + description: Optional list of advanced Kafka producer configuration options, + defined as key-value pairs. + items: + $ref: '#/components/schemas/ObservabilityPipelineKafkaLibrdkafkaOption' + type: array + message_timeout_ms: + description: Maximum time in milliseconds to wait for message delivery confirmation. + example: 300000 + format: int64 + minimum: 1 + type: integer + rate_limit_duration_secs: + description: Duration in seconds for the rate limit window. + example: 1 + format: int64 + minimum: 1 + type: integer + rate_limit_num: + description: Maximum number of messages allowed per rate limit duration. + example: 1000 + format: int64 + minimum: 1 + type: integer + sasl: + $ref: '#/components/schemas/ObservabilityPipelineKafkaSasl' + socket_timeout_ms: + description: Socket timeout in milliseconds for network requests. + example: 60000 + format: int64 + maximum: 300000 + minimum: 10 + type: integer + tls: + $ref: '#/components/schemas/ObservabilityPipelineTls' + topic: + description: The Kafka topic name to publish logs to. + example: logs-topic + type: string + type: + $ref: '#/components/schemas/ObservabilityPipelineKafkaDestinationType' + required: + - id + - type + - inputs + - topic + - encoding + type: object + ObservabilityPipelineKafkaDestinationCompression: + description: Compression codec for Kafka messages. + enum: + - none + - gzip + - snappy + - lz4 + - zstd + example: gzip + type: string + x-enum-varnames: + - NONE + - GZIP + - SNAPPY + - LZ4 + - ZSTD + ObservabilityPipelineKafkaDestinationEncoding: + description: Encoding format for log events. + enum: + - json + - raw_message + example: json + type: string + x-enum-varnames: + - JSON + - RAW_MESSAGE + ObservabilityPipelineKafkaDestinationType: + default: kafka + description: The destination type. The value should always be `kafka`. + enum: + - kafka + example: kafka + type: string + x-enum-varnames: + - KAFKA + ObservabilityPipelineKafkaLibrdkafkaOption: + description: Represents a key-value pair used to configure low-level `librdkafka` + client options for Kafka source and destination, such as timeouts, buffer + sizes, and security settings. + properties: + name: + description: The name of the `librdkafka` configuration option to set. + example: fetch.message.max.bytes + type: string + value: + description: The value assigned to the specified `librdkafka` configuration + option. + example: '1048576' + type: string + required: + - name + - value + type: object + ObservabilityPipelineKafkaSasl: + description: Specifies the SASL mechanism for authenticating with a Kafka cluster. + properties: + mechanism: + $ref: '#/components/schemas/ObservabilityPipelineKafkaSaslMechanism' + type: object + ObservabilityPipelineKafkaSaslMechanism: + description: SASL mechanism used for Kafka authentication. + enum: + - PLAIN + - SCRAM-SHA-256 + - SCRAM-SHA-512 + type: string + x-enum-varnames: + - PLAIN + - SCRAMNOT_SHANOT_256 + - SCRAMNOT_SHANOT_512 ObservabilityPipelineKafkaSource: description: The `kafka` source ingests data from Apache Kafka topics. properties: @@ -36843,10 +37021,10 @@ components: description: Optional list of advanced Kafka client configuration options, defined as key-value pairs. items: - $ref: '#/components/schemas/ObservabilityPipelineKafkaSourceLibrdkafkaOption' + $ref: '#/components/schemas/ObservabilityPipelineKafkaLibrdkafkaOption' type: array sasl: - $ref: '#/components/schemas/ObservabilityPipelineKafkaSourceSasl' + $ref: '#/components/schemas/ObservabilityPipelineKafkaSasl' tls: $ref: '#/components/schemas/ObservabilityPipelineTls' topics: @@ -36866,30 +37044,6 @@ components: - group_id - topics type: object - ObservabilityPipelineKafkaSourceLibrdkafkaOption: - description: Represents a key-value pair used to configure low-level `librdkafka` - client options for Kafka sources, such as timeouts, buffer sizes, and security - settings. - properties: - name: - description: The name of the `librdkafka` configuration option to set. - example: fetch.message.max.bytes - type: string - value: - description: The value assigned to the specified `librdkafka` configuration - option. - example: '1048576' - type: string - required: - - name - - value - type: object - ObservabilityPipelineKafkaSourceSasl: - description: Specifies the SASL mechanism for authenticating with a Kafka cluster. - properties: - mechanism: - $ref: '#/components/schemas/ObservabilityPipelinePipelineKafkaSourceSaslMechanism' - type: object ObservabilityPipelineKafkaSourceType: default: kafka description: The source type. The value should always be `kafka`. @@ -37279,17 +37433,6 @@ components: type: string x-enum-varnames: - PARSE_JSON - ObservabilityPipelinePipelineKafkaSourceSaslMechanism: - description: SASL mechanism used for Kafka authentication. - enum: - - PLAIN - - SCRAM-SHA-256 - - SCRAM-SHA-512 - type: string - x-enum-varnames: - - PLAIN - - SCRAMNOT_SHANOT_256 - - SCRAMNOT_SHANOT_512 ObservabilityPipelineQuotaProcessor: description: The Quota Processor measures logging traffic for logs that match a specified filter. When the configured daily quota is met, the processor diff --git a/docs/datadog_api_client.v2.model.rst b/docs/datadog_api_client.v2.model.rst index 2e859a4f0f..a9188b4049 100644 --- a/docs/datadog_api_client.v2.model.rst +++ b/docs/datadog_api_client.v2.model.rst @@ -15467,6 +15467,20 @@ datadog\_api\_client.v2.model.observability\_pipeline\_aws\_auth module :members: :show-inheritance: +datadog\_api\_client.v2.model.observability\_pipeline\_cloud\_prem\_destination module +-------------------------------------------------------------------------------------- + +.. automodule:: datadog_api_client.v2.model.observability_pipeline_cloud_prem_destination + :members: + :show-inheritance: + +datadog\_api\_client.v2.model.observability\_pipeline\_cloud\_prem\_destination\_type module +-------------------------------------------------------------------------------------------- + +.. automodule:: datadog_api_client.v2.model.observability_pipeline_cloud_prem_destination_type + :members: + :show-inheritance: + datadog\_api\_client.v2.model.observability\_pipeline\_config module -------------------------------------------------------------------- @@ -15978,24 +15992,59 @@ datadog\_api\_client.v2.model.observability\_pipeline\_http\_server\_source\_typ :members: :show-inheritance: -datadog\_api\_client.v2.model.observability\_pipeline\_kafka\_source module ---------------------------------------------------------------------------- +datadog\_api\_client.v2.model.observability\_pipeline\_kafka\_destination module +-------------------------------------------------------------------------------- -.. automodule:: datadog_api_client.v2.model.observability_pipeline_kafka_source +.. automodule:: datadog_api_client.v2.model.observability_pipeline_kafka_destination :members: :show-inheritance: -datadog\_api\_client.v2.model.observability\_pipeline\_kafka\_source\_librdkafka\_option module ------------------------------------------------------------------------------------------------ +datadog\_api\_client.v2.model.observability\_pipeline\_kafka\_destination\_compression module +--------------------------------------------------------------------------------------------- -.. automodule:: datadog_api_client.v2.model.observability_pipeline_kafka_source_librdkafka_option +.. automodule:: datadog_api_client.v2.model.observability_pipeline_kafka_destination_compression :members: :show-inheritance: -datadog\_api\_client.v2.model.observability\_pipeline\_kafka\_source\_sasl module ---------------------------------------------------------------------------------- +datadog\_api\_client.v2.model.observability\_pipeline\_kafka\_destination\_encoding module +------------------------------------------------------------------------------------------ + +.. automodule:: datadog_api_client.v2.model.observability_pipeline_kafka_destination_encoding + :members: + :show-inheritance: + +datadog\_api\_client.v2.model.observability\_pipeline\_kafka\_destination\_type module +-------------------------------------------------------------------------------------- + +.. automodule:: datadog_api_client.v2.model.observability_pipeline_kafka_destination_type + :members: + :show-inheritance: + +datadog\_api\_client.v2.model.observability\_pipeline\_kafka\_librdkafka\_option module +--------------------------------------------------------------------------------------- + +.. automodule:: datadog_api_client.v2.model.observability_pipeline_kafka_librdkafka_option + :members: + :show-inheritance: + +datadog\_api\_client.v2.model.observability\_pipeline\_kafka\_sasl module +------------------------------------------------------------------------- + +.. automodule:: datadog_api_client.v2.model.observability_pipeline_kafka_sasl + :members: + :show-inheritance: + +datadog\_api\_client.v2.model.observability\_pipeline\_kafka\_sasl\_mechanism module +------------------------------------------------------------------------------------ -.. automodule:: datadog_api_client.v2.model.observability_pipeline_kafka_source_sasl +.. automodule:: datadog_api_client.v2.model.observability_pipeline_kafka_sasl_mechanism + :members: + :show-inheritance: + +datadog\_api\_client.v2.model.observability\_pipeline\_kafka\_source module +--------------------------------------------------------------------------- + +.. automodule:: datadog_api_client.v2.model.observability_pipeline_kafka_source :members: :show-inheritance: @@ -16153,13 +16202,6 @@ datadog\_api\_client.v2.model.observability\_pipeline\_parse\_json\_processor\_t :members: :show-inheritance: -datadog\_api\_client.v2.model.observability\_pipeline\_pipeline\_kafka\_source\_sasl\_mechanism module ------------------------------------------------------------------------------------------------------- - -.. automodule:: datadog_api_client.v2.model.observability_pipeline_pipeline_kafka_source_sasl_mechanism - :members: - :show-inheritance: - datadog\_api\_client.v2.model.observability\_pipeline\_quota\_processor module ------------------------------------------------------------------------------ diff --git a/src/datadog_api_client/v2/model/observability_pipeline_cloud_prem_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_cloud_prem_destination.py new file mode 100644 index 0000000000..4d163daf30 --- /dev/null +++ b/src/datadog_api_client/v2/model/observability_pipeline_cloud_prem_destination.py @@ -0,0 +1,56 @@ +# Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License. +# This product includes software developed at Datadog (https://www.datadoghq.com/). +# Copyright 2019-Present Datadog, Inc. +from __future__ import annotations + +from typing import List, TYPE_CHECKING + +from datadog_api_client.model_utils import ( + ModelNormal, + cached_property, +) + + +if TYPE_CHECKING: + from datadog_api_client.v2.model.observability_pipeline_cloud_prem_destination_type import ( + ObservabilityPipelineCloudPremDestinationType, + ) + + +class ObservabilityPipelineCloudPremDestination(ModelNormal): + @cached_property + def openapi_types(_): + from datadog_api_client.v2.model.observability_pipeline_cloud_prem_destination_type import ( + ObservabilityPipelineCloudPremDestinationType, + ) + + return { + "id": (str,), + "inputs": ([str],), + "type": (ObservabilityPipelineCloudPremDestinationType,), + } + + attribute_map = { + "id": "id", + "inputs": "inputs", + "type": "type", + } + + def __init__(self_, id: str, inputs: List[str], type: ObservabilityPipelineCloudPremDestinationType, **kwargs): + """ + The ``cloud_prem`` destination sends logs to Datadog CloudPrem. + + :param id: The unique identifier for this component. + :type id: str + + :param inputs: A list of component IDs whose output is used as the ``input`` for this component. + :type inputs: [str] + + :param type: The destination type. The value should always be ``cloud_prem``. + :type type: ObservabilityPipelineCloudPremDestinationType + """ + super().__init__(kwargs) + + self_.id = id + self_.inputs = inputs + self_.type = type diff --git a/src/datadog_api_client/v2/model/observability_pipeline_cloud_prem_destination_type.py b/src/datadog_api_client/v2/model/observability_pipeline_cloud_prem_destination_type.py new file mode 100644 index 0000000000..88110c24ef --- /dev/null +++ b/src/datadog_api_client/v2/model/observability_pipeline_cloud_prem_destination_type.py @@ -0,0 +1,35 @@ +# Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License. +# This product includes software developed at Datadog (https://www.datadoghq.com/). +# Copyright 2019-Present Datadog, Inc. +from __future__ import annotations + + +from datadog_api_client.model_utils import ( + ModelSimple, + cached_property, +) + +from typing import ClassVar + + +class ObservabilityPipelineCloudPremDestinationType(ModelSimple): + """ + The destination type. The value should always be `cloud_prem`. + + :param value: If omitted defaults to "cloud_prem". Must be one of ["cloud_prem"]. + :type value: str + """ + + allowed_values = { + "cloud_prem", + } + CLOUD_PREM: ClassVar["ObservabilityPipelineCloudPremDestinationType"] + + @cached_property + def openapi_types(_): + return { + "value": (str,), + } + + +ObservabilityPipelineCloudPremDestinationType.CLOUD_PREM = ObservabilityPipelineCloudPremDestinationType("cloud_prem") diff --git a/src/datadog_api_client/v2/model/observability_pipeline_config.py b/src/datadog_api_client/v2/model/observability_pipeline_config.py index 48cf842a5d..5db44c8fee 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_config.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_config.py @@ -26,6 +26,9 @@ from datadog_api_client.v2.model.observability_pipeline_datadog_logs_destination import ( ObservabilityPipelineDatadogLogsDestination, ) + from datadog_api_client.v2.model.observability_pipeline_cloud_prem_destination import ( + ObservabilityPipelineCloudPremDestination, + ) from datadog_api_client.v2.model.observability_pipeline_amazon_s3_destination import ( ObservabilityPipelineAmazonS3Destination, ) @@ -76,6 +79,9 @@ from datadog_api_client.v2.model.observability_pipeline_google_pub_sub_destination import ( ObservabilityPipelineGooglePubSubDestination, ) + from datadog_api_client.v2.model.observability_pipeline_kafka_destination import ( + ObservabilityPipelineKafkaDestination, + ) from datadog_api_client.v2.model.observability_pipeline_kafka_source import ObservabilityPipelineKafkaSource from datadog_api_client.v2.model.observability_pipeline_datadog_agent_source import ( ObservabilityPipelineDatadogAgentSource, @@ -143,6 +149,7 @@ def __init__( Union[ ObservabilityPipelineConfigDestinationItem, ObservabilityPipelineDatadogLogsDestination, + ObservabilityPipelineCloudPremDestination, ObservabilityPipelineAmazonS3Destination, ObservabilityPipelineGoogleCloudStorageDestination, ObservabilityPipelineSplunkHecDestination, @@ -161,6 +168,7 @@ def __init__( ObservabilityPipelineAmazonSecurityLakeDestination, ObservabilityPipelineCrowdStrikeNextGenSiemDestination, ObservabilityPipelineGooglePubSubDestination, + ObservabilityPipelineKafkaDestination, ] ], sources: List[ diff --git a/src/datadog_api_client/v2/model/observability_pipeline_config_destination_item.py b/src/datadog_api_client/v2/model/observability_pipeline_config_destination_item.py index df018bec4e..40a3d9e346 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_config_destination_item.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_config_destination_item.py @@ -124,6 +124,30 @@ def __init__(self, **kwargs): :param topic: The Pub/Sub topic name to publish logs to. :type topic: str + + :param headers_key: The field name to use for Kafka message headers. + :type headers_key: str, optional + + :param key_field: The field name to use as the Kafka message key. + :type key_field: str, optional + + :param librdkafka_options: Optional list of advanced Kafka producer configuration options, defined as key-value pairs. + :type librdkafka_options: [ObservabilityPipelineKafkaLibrdkafkaOption], optional + + :param message_timeout_ms: Maximum time in milliseconds to wait for message delivery confirmation. + :type message_timeout_ms: int, optional + + :param rate_limit_duration_secs: Duration in seconds for the rate limit window. + :type rate_limit_duration_secs: int, optional + + :param rate_limit_num: Maximum number of messages allowed per rate limit duration. + :type rate_limit_num: int, optional + + :param sasl: Specifies the SASL mechanism for authenticating with a Kafka cluster. + :type sasl: ObservabilityPipelineKafkaSasl, optional + + :param socket_timeout_ms: Socket timeout in milliseconds for network requests. + :type socket_timeout_ms: int, optional """ super().__init__(kwargs) @@ -139,6 +163,9 @@ def _composed_schemas(_): from datadog_api_client.v2.model.observability_pipeline_datadog_logs_destination import ( ObservabilityPipelineDatadogLogsDestination, ) + from datadog_api_client.v2.model.observability_pipeline_cloud_prem_destination import ( + ObservabilityPipelineCloudPremDestination, + ) from datadog_api_client.v2.model.observability_pipeline_amazon_s3_destination import ( ObservabilityPipelineAmazonS3Destination, ) @@ -189,10 +216,14 @@ def _composed_schemas(_): from datadog_api_client.v2.model.observability_pipeline_google_pub_sub_destination import ( ObservabilityPipelineGooglePubSubDestination, ) + from datadog_api_client.v2.model.observability_pipeline_kafka_destination import ( + ObservabilityPipelineKafkaDestination, + ) return { "oneOf": [ ObservabilityPipelineDatadogLogsDestination, + ObservabilityPipelineCloudPremDestination, ObservabilityPipelineAmazonS3Destination, ObservabilityPipelineGoogleCloudStorageDestination, ObservabilityPipelineSplunkHecDestination, @@ -211,5 +242,6 @@ def _composed_schemas(_): ObservabilityPipelineAmazonSecurityLakeDestination, ObservabilityPipelineCrowdStrikeNextGenSiemDestination, ObservabilityPipelineGooglePubSubDestination, + ObservabilityPipelineKafkaDestination, ], } diff --git a/src/datadog_api_client/v2/model/observability_pipeline_config_source_item.py b/src/datadog_api_client/v2/model/observability_pipeline_config_source_item.py index 04e30172c1..e3f8045371 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_config_source_item.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_config_source_item.py @@ -22,10 +22,10 @@ def __init__(self, **kwargs): :type id: str :param librdkafka_options: Optional list of advanced Kafka client configuration options, defined as key-value pairs. - :type librdkafka_options: [ObservabilityPipelineKafkaSourceLibrdkafkaOption], optional + :type librdkafka_options: [ObservabilityPipelineKafkaLibrdkafkaOption], optional :param sasl: Specifies the SASL mechanism for authenticating with a Kafka cluster. - :type sasl: ObservabilityPipelineKafkaSourceSasl, optional + :type sasl: ObservabilityPipelineKafkaSasl, optional :param tls: Configuration for enabling TLS encryption between the pipeline component and external services. :type tls: ObservabilityPipelineTls, optional diff --git a/src/datadog_api_client/v2/model/observability_pipeline_kafka_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_kafka_destination.py new file mode 100644 index 0000000000..9817607ee4 --- /dev/null +++ b/src/datadog_api_client/v2/model/observability_pipeline_kafka_destination.py @@ -0,0 +1,196 @@ +# Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License. +# This product includes software developed at Datadog (https://www.datadoghq.com/). +# Copyright 2019-Present Datadog, Inc. +from __future__ import annotations + +from typing import List, Union, TYPE_CHECKING + +from datadog_api_client.model_utils import ( + ModelNormal, + cached_property, + unset, + UnsetType, +) + + +if TYPE_CHECKING: + from datadog_api_client.v2.model.observability_pipeline_kafka_destination_compression import ( + ObservabilityPipelineKafkaDestinationCompression, + ) + from datadog_api_client.v2.model.observability_pipeline_kafka_destination_encoding import ( + ObservabilityPipelineKafkaDestinationEncoding, + ) + from datadog_api_client.v2.model.observability_pipeline_kafka_librdkafka_option import ( + ObservabilityPipelineKafkaLibrdkafkaOption, + ) + from datadog_api_client.v2.model.observability_pipeline_kafka_sasl import ObservabilityPipelineKafkaSasl + from datadog_api_client.v2.model.observability_pipeline_tls import ObservabilityPipelineTls + from datadog_api_client.v2.model.observability_pipeline_kafka_destination_type import ( + ObservabilityPipelineKafkaDestinationType, + ) + + +class ObservabilityPipelineKafkaDestination(ModelNormal): + validations = { + "message_timeout_ms": { + "inclusive_minimum": 1, + }, + "rate_limit_duration_secs": { + "inclusive_minimum": 1, + }, + "rate_limit_num": { + "inclusive_minimum": 1, + }, + "socket_timeout_ms": { + "inclusive_maximum": 300000, + "inclusive_minimum": 10, + }, + } + + @cached_property + def openapi_types(_): + from datadog_api_client.v2.model.observability_pipeline_kafka_destination_compression import ( + ObservabilityPipelineKafkaDestinationCompression, + ) + from datadog_api_client.v2.model.observability_pipeline_kafka_destination_encoding import ( + ObservabilityPipelineKafkaDestinationEncoding, + ) + from datadog_api_client.v2.model.observability_pipeline_kafka_librdkafka_option import ( + ObservabilityPipelineKafkaLibrdkafkaOption, + ) + from datadog_api_client.v2.model.observability_pipeline_kafka_sasl import ObservabilityPipelineKafkaSasl + from datadog_api_client.v2.model.observability_pipeline_tls import ObservabilityPipelineTls + from datadog_api_client.v2.model.observability_pipeline_kafka_destination_type import ( + ObservabilityPipelineKafkaDestinationType, + ) + + return { + "compression": (ObservabilityPipelineKafkaDestinationCompression,), + "encoding": (ObservabilityPipelineKafkaDestinationEncoding,), + "headers_key": (str,), + "id": (str,), + "inputs": ([str],), + "key_field": (str,), + "librdkafka_options": ([ObservabilityPipelineKafkaLibrdkafkaOption],), + "message_timeout_ms": (int,), + "rate_limit_duration_secs": (int,), + "rate_limit_num": (int,), + "sasl": (ObservabilityPipelineKafkaSasl,), + "socket_timeout_ms": (int,), + "tls": (ObservabilityPipelineTls,), + "topic": (str,), + "type": (ObservabilityPipelineKafkaDestinationType,), + } + + attribute_map = { + "compression": "compression", + "encoding": "encoding", + "headers_key": "headers_key", + "id": "id", + "inputs": "inputs", + "key_field": "key_field", + "librdkafka_options": "librdkafka_options", + "message_timeout_ms": "message_timeout_ms", + "rate_limit_duration_secs": "rate_limit_duration_secs", + "rate_limit_num": "rate_limit_num", + "sasl": "sasl", + "socket_timeout_ms": "socket_timeout_ms", + "tls": "tls", + "topic": "topic", + "type": "type", + } + + def __init__( + self_, + encoding: ObservabilityPipelineKafkaDestinationEncoding, + id: str, + inputs: List[str], + topic: str, + type: ObservabilityPipelineKafkaDestinationType, + compression: Union[ObservabilityPipelineKafkaDestinationCompression, UnsetType] = unset, + headers_key: Union[str, UnsetType] = unset, + key_field: Union[str, UnsetType] = unset, + librdkafka_options: Union[List[ObservabilityPipelineKafkaLibrdkafkaOption], UnsetType] = unset, + message_timeout_ms: Union[int, UnsetType] = unset, + rate_limit_duration_secs: Union[int, UnsetType] = unset, + rate_limit_num: Union[int, UnsetType] = unset, + sasl: Union[ObservabilityPipelineKafkaSasl, UnsetType] = unset, + socket_timeout_ms: Union[int, UnsetType] = unset, + tls: Union[ObservabilityPipelineTls, UnsetType] = unset, + **kwargs, + ): + """ + The ``kafka`` destination sends logs to Apache Kafka topics. + + :param compression: Compression codec for Kafka messages. + :type compression: ObservabilityPipelineKafkaDestinationCompression, optional + + :param encoding: Encoding format for log events. + :type encoding: ObservabilityPipelineKafkaDestinationEncoding + + :param headers_key: The field name to use for Kafka message headers. + :type headers_key: str, optional + + :param id: The unique identifier for this component. + :type id: str + + :param inputs: A list of component IDs whose output is used as the ``input`` for this component. + :type inputs: [str] + + :param key_field: The field name to use as the Kafka message key. + :type key_field: str, optional + + :param librdkafka_options: Optional list of advanced Kafka producer configuration options, defined as key-value pairs. + :type librdkafka_options: [ObservabilityPipelineKafkaLibrdkafkaOption], optional + + :param message_timeout_ms: Maximum time in milliseconds to wait for message delivery confirmation. + :type message_timeout_ms: int, optional + + :param rate_limit_duration_secs: Duration in seconds for the rate limit window. + :type rate_limit_duration_secs: int, optional + + :param rate_limit_num: Maximum number of messages allowed per rate limit duration. + :type rate_limit_num: int, optional + + :param sasl: Specifies the SASL mechanism for authenticating with a Kafka cluster. + :type sasl: ObservabilityPipelineKafkaSasl, optional + + :param socket_timeout_ms: Socket timeout in milliseconds for network requests. + :type socket_timeout_ms: int, optional + + :param tls: Configuration for enabling TLS encryption between the pipeline component and external services. + :type tls: ObservabilityPipelineTls, optional + + :param topic: The Kafka topic name to publish logs to. + :type topic: str + + :param type: The destination type. The value should always be ``kafka``. + :type type: ObservabilityPipelineKafkaDestinationType + """ + if compression is not unset: + kwargs["compression"] = compression + if headers_key is not unset: + kwargs["headers_key"] = headers_key + if key_field is not unset: + kwargs["key_field"] = key_field + if librdkafka_options is not unset: + kwargs["librdkafka_options"] = librdkafka_options + if message_timeout_ms is not unset: + kwargs["message_timeout_ms"] = message_timeout_ms + if rate_limit_duration_secs is not unset: + kwargs["rate_limit_duration_secs"] = rate_limit_duration_secs + if rate_limit_num is not unset: + kwargs["rate_limit_num"] = rate_limit_num + if sasl is not unset: + kwargs["sasl"] = sasl + if socket_timeout_ms is not unset: + kwargs["socket_timeout_ms"] = socket_timeout_ms + if tls is not unset: + kwargs["tls"] = tls + super().__init__(kwargs) + + self_.encoding = encoding + self_.id = id + self_.inputs = inputs + self_.topic = topic + self_.type = type diff --git a/src/datadog_api_client/v2/model/observability_pipeline_kafka_destination_compression.py b/src/datadog_api_client/v2/model/observability_pipeline_kafka_destination_compression.py new file mode 100644 index 0000000000..3cd49d2960 --- /dev/null +++ b/src/datadog_api_client/v2/model/observability_pipeline_kafka_destination_compression.py @@ -0,0 +1,47 @@ +# Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License. +# This product includes software developed at Datadog (https://www.datadoghq.com/). +# Copyright 2019-Present Datadog, Inc. +from __future__ import annotations + + +from datadog_api_client.model_utils import ( + ModelSimple, + cached_property, +) + +from typing import ClassVar + + +class ObservabilityPipelineKafkaDestinationCompression(ModelSimple): + """ + Compression codec for Kafka messages. + + :param value: Must be one of ["none", "gzip", "snappy", "lz4", "zstd"]. + :type value: str + """ + + allowed_values = { + "none", + "gzip", + "snappy", + "lz4", + "zstd", + } + NONE: ClassVar["ObservabilityPipelineKafkaDestinationCompression"] + GZIP: ClassVar["ObservabilityPipelineKafkaDestinationCompression"] + SNAPPY: ClassVar["ObservabilityPipelineKafkaDestinationCompression"] + LZ4: ClassVar["ObservabilityPipelineKafkaDestinationCompression"] + ZSTD: ClassVar["ObservabilityPipelineKafkaDestinationCompression"] + + @cached_property + def openapi_types(_): + return { + "value": (str,), + } + + +ObservabilityPipelineKafkaDestinationCompression.NONE = ObservabilityPipelineKafkaDestinationCompression("none") +ObservabilityPipelineKafkaDestinationCompression.GZIP = ObservabilityPipelineKafkaDestinationCompression("gzip") +ObservabilityPipelineKafkaDestinationCompression.SNAPPY = ObservabilityPipelineKafkaDestinationCompression("snappy") +ObservabilityPipelineKafkaDestinationCompression.LZ4 = ObservabilityPipelineKafkaDestinationCompression("lz4") +ObservabilityPipelineKafkaDestinationCompression.ZSTD = ObservabilityPipelineKafkaDestinationCompression("zstd") diff --git a/src/datadog_api_client/v2/model/observability_pipeline_kafka_destination_encoding.py b/src/datadog_api_client/v2/model/observability_pipeline_kafka_destination_encoding.py new file mode 100644 index 0000000000..99db79c36e --- /dev/null +++ b/src/datadog_api_client/v2/model/observability_pipeline_kafka_destination_encoding.py @@ -0,0 +1,38 @@ +# Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License. +# This product includes software developed at Datadog (https://www.datadoghq.com/). +# Copyright 2019-Present Datadog, Inc. +from __future__ import annotations + + +from datadog_api_client.model_utils import ( + ModelSimple, + cached_property, +) + +from typing import ClassVar + + +class ObservabilityPipelineKafkaDestinationEncoding(ModelSimple): + """ + Encoding format for log events. + + :param value: Must be one of ["json", "raw_message"]. + :type value: str + """ + + allowed_values = { + "json", + "raw_message", + } + JSON: ClassVar["ObservabilityPipelineKafkaDestinationEncoding"] + RAW_MESSAGE: ClassVar["ObservabilityPipelineKafkaDestinationEncoding"] + + @cached_property + def openapi_types(_): + return { + "value": (str,), + } + + +ObservabilityPipelineKafkaDestinationEncoding.JSON = ObservabilityPipelineKafkaDestinationEncoding("json") +ObservabilityPipelineKafkaDestinationEncoding.RAW_MESSAGE = ObservabilityPipelineKafkaDestinationEncoding("raw_message") diff --git a/src/datadog_api_client/v2/model/observability_pipeline_kafka_destination_type.py b/src/datadog_api_client/v2/model/observability_pipeline_kafka_destination_type.py new file mode 100644 index 0000000000..e2e290b169 --- /dev/null +++ b/src/datadog_api_client/v2/model/observability_pipeline_kafka_destination_type.py @@ -0,0 +1,35 @@ +# Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License. +# This product includes software developed at Datadog (https://www.datadoghq.com/). +# Copyright 2019-Present Datadog, Inc. +from __future__ import annotations + + +from datadog_api_client.model_utils import ( + ModelSimple, + cached_property, +) + +from typing import ClassVar + + +class ObservabilityPipelineKafkaDestinationType(ModelSimple): + """ + The destination type. The value should always be `kafka`. + + :param value: If omitted defaults to "kafka". Must be one of ["kafka"]. + :type value: str + """ + + allowed_values = { + "kafka", + } + KAFKA: ClassVar["ObservabilityPipelineKafkaDestinationType"] + + @cached_property + def openapi_types(_): + return { + "value": (str,), + } + + +ObservabilityPipelineKafkaDestinationType.KAFKA = ObservabilityPipelineKafkaDestinationType("kafka") diff --git a/src/datadog_api_client/v2/model/observability_pipeline_kafka_source_librdkafka_option.py b/src/datadog_api_client/v2/model/observability_pipeline_kafka_librdkafka_option.py similarity index 84% rename from src/datadog_api_client/v2/model/observability_pipeline_kafka_source_librdkafka_option.py rename to src/datadog_api_client/v2/model/observability_pipeline_kafka_librdkafka_option.py index 4099a196cd..a7e29aa09b 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_kafka_source_librdkafka_option.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_kafka_librdkafka_option.py @@ -10,7 +10,7 @@ ) -class ObservabilityPipelineKafkaSourceLibrdkafkaOption(ModelNormal): +class ObservabilityPipelineKafkaLibrdkafkaOption(ModelNormal): @cached_property def openapi_types(_): return { @@ -25,7 +25,7 @@ def openapi_types(_): def __init__(self_, name: str, value: str, **kwargs): """ - Represents a key-value pair used to configure low-level ``librdkafka`` client options for Kafka sources, such as timeouts, buffer sizes, and security settings. + Represents a key-value pair used to configure low-level ``librdkafka`` client options for Kafka source and destination, such as timeouts, buffer sizes, and security settings. :param name: The name of the ``librdkafka`` configuration option to set. :type name: str diff --git a/src/datadog_api_client/v2/model/observability_pipeline_kafka_source_sasl.py b/src/datadog_api_client/v2/model/observability_pipeline_kafka_sasl.py similarity index 59% rename from src/datadog_api_client/v2/model/observability_pipeline_kafka_source_sasl.py rename to src/datadog_api_client/v2/model/observability_pipeline_kafka_sasl.py index 88f6e0aaab..e6d42bc1c8 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_kafka_source_sasl.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_kafka_sasl.py @@ -14,34 +14,32 @@ if TYPE_CHECKING: - from datadog_api_client.v2.model.observability_pipeline_pipeline_kafka_source_sasl_mechanism import ( - ObservabilityPipelinePipelineKafkaSourceSaslMechanism, + from datadog_api_client.v2.model.observability_pipeline_kafka_sasl_mechanism import ( + ObservabilityPipelineKafkaSaslMechanism, ) -class ObservabilityPipelineKafkaSourceSasl(ModelNormal): +class ObservabilityPipelineKafkaSasl(ModelNormal): @cached_property def openapi_types(_): - from datadog_api_client.v2.model.observability_pipeline_pipeline_kafka_source_sasl_mechanism import ( - ObservabilityPipelinePipelineKafkaSourceSaslMechanism, + from datadog_api_client.v2.model.observability_pipeline_kafka_sasl_mechanism import ( + ObservabilityPipelineKafkaSaslMechanism, ) return { - "mechanism": (ObservabilityPipelinePipelineKafkaSourceSaslMechanism,), + "mechanism": (ObservabilityPipelineKafkaSaslMechanism,), } attribute_map = { "mechanism": "mechanism", } - def __init__( - self_, mechanism: Union[ObservabilityPipelinePipelineKafkaSourceSaslMechanism, UnsetType] = unset, **kwargs - ): + def __init__(self_, mechanism: Union[ObservabilityPipelineKafkaSaslMechanism, UnsetType] = unset, **kwargs): """ Specifies the SASL mechanism for authenticating with a Kafka cluster. :param mechanism: SASL mechanism used for Kafka authentication. - :type mechanism: ObservabilityPipelinePipelineKafkaSourceSaslMechanism, optional + :type mechanism: ObservabilityPipelineKafkaSaslMechanism, optional """ if mechanism is not unset: kwargs["mechanism"] = mechanism diff --git a/src/datadog_api_client/v2/model/observability_pipeline_pipeline_kafka_source_sasl_mechanism.py b/src/datadog_api_client/v2/model/observability_pipeline_kafka_sasl_mechanism.py similarity index 50% rename from src/datadog_api_client/v2/model/observability_pipeline_pipeline_kafka_source_sasl_mechanism.py rename to src/datadog_api_client/v2/model/observability_pipeline_kafka_sasl_mechanism.py index db414b0a6f..2f261fd1aa 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_pipeline_kafka_source_sasl_mechanism.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_kafka_sasl_mechanism.py @@ -12,7 +12,7 @@ from typing import ClassVar -class ObservabilityPipelinePipelineKafkaSourceSaslMechanism(ModelSimple): +class ObservabilityPipelineKafkaSaslMechanism(ModelSimple): """ SASL mechanism used for Kafka authentication. @@ -25,9 +25,9 @@ class ObservabilityPipelinePipelineKafkaSourceSaslMechanism(ModelSimple): "SCRAM-SHA-256", "SCRAM-SHA-512", } - PLAIN: ClassVar["ObservabilityPipelinePipelineKafkaSourceSaslMechanism"] - SCRAMNOT_SHANOT_256: ClassVar["ObservabilityPipelinePipelineKafkaSourceSaslMechanism"] - SCRAMNOT_SHANOT_512: ClassVar["ObservabilityPipelinePipelineKafkaSourceSaslMechanism"] + PLAIN: ClassVar["ObservabilityPipelineKafkaSaslMechanism"] + SCRAMNOT_SHANOT_256: ClassVar["ObservabilityPipelineKafkaSaslMechanism"] + SCRAMNOT_SHANOT_512: ClassVar["ObservabilityPipelineKafkaSaslMechanism"] @cached_property def openapi_types(_): @@ -36,12 +36,6 @@ def openapi_types(_): } -ObservabilityPipelinePipelineKafkaSourceSaslMechanism.PLAIN = ObservabilityPipelinePipelineKafkaSourceSaslMechanism( - "PLAIN" -) -ObservabilityPipelinePipelineKafkaSourceSaslMechanism.SCRAMNOT_SHANOT_256 = ( - ObservabilityPipelinePipelineKafkaSourceSaslMechanism("SCRAM-SHA-256") -) -ObservabilityPipelinePipelineKafkaSourceSaslMechanism.SCRAMNOT_SHANOT_512 = ( - ObservabilityPipelinePipelineKafkaSourceSaslMechanism("SCRAM-SHA-512") -) +ObservabilityPipelineKafkaSaslMechanism.PLAIN = ObservabilityPipelineKafkaSaslMechanism("PLAIN") +ObservabilityPipelineKafkaSaslMechanism.SCRAMNOT_SHANOT_256 = ObservabilityPipelineKafkaSaslMechanism("SCRAM-SHA-256") +ObservabilityPipelineKafkaSaslMechanism.SCRAMNOT_SHANOT_512 = ObservabilityPipelineKafkaSaslMechanism("SCRAM-SHA-512") diff --git a/src/datadog_api_client/v2/model/observability_pipeline_kafka_source.py b/src/datadog_api_client/v2/model/observability_pipeline_kafka_source.py index 3ba6cfe651..bb5ee4cb79 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_kafka_source.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_kafka_source.py @@ -14,12 +14,10 @@ if TYPE_CHECKING: - from datadog_api_client.v2.model.observability_pipeline_kafka_source_librdkafka_option import ( - ObservabilityPipelineKafkaSourceLibrdkafkaOption, - ) - from datadog_api_client.v2.model.observability_pipeline_kafka_source_sasl import ( - ObservabilityPipelineKafkaSourceSasl, + from datadog_api_client.v2.model.observability_pipeline_kafka_librdkafka_option import ( + ObservabilityPipelineKafkaLibrdkafkaOption, ) + from datadog_api_client.v2.model.observability_pipeline_kafka_sasl import ObservabilityPipelineKafkaSasl from datadog_api_client.v2.model.observability_pipeline_tls import ObservabilityPipelineTls from datadog_api_client.v2.model.observability_pipeline_kafka_source_type import ( ObservabilityPipelineKafkaSourceType, @@ -29,12 +27,10 @@ class ObservabilityPipelineKafkaSource(ModelNormal): @cached_property def openapi_types(_): - from datadog_api_client.v2.model.observability_pipeline_kafka_source_librdkafka_option import ( - ObservabilityPipelineKafkaSourceLibrdkafkaOption, - ) - from datadog_api_client.v2.model.observability_pipeline_kafka_source_sasl import ( - ObservabilityPipelineKafkaSourceSasl, + from datadog_api_client.v2.model.observability_pipeline_kafka_librdkafka_option import ( + ObservabilityPipelineKafkaLibrdkafkaOption, ) + from datadog_api_client.v2.model.observability_pipeline_kafka_sasl import ObservabilityPipelineKafkaSasl from datadog_api_client.v2.model.observability_pipeline_tls import ObservabilityPipelineTls from datadog_api_client.v2.model.observability_pipeline_kafka_source_type import ( ObservabilityPipelineKafkaSourceType, @@ -43,8 +39,8 @@ def openapi_types(_): return { "group_id": (str,), "id": (str,), - "librdkafka_options": ([ObservabilityPipelineKafkaSourceLibrdkafkaOption],), - "sasl": (ObservabilityPipelineKafkaSourceSasl,), + "librdkafka_options": ([ObservabilityPipelineKafkaLibrdkafkaOption],), + "sasl": (ObservabilityPipelineKafkaSasl,), "tls": (ObservabilityPipelineTls,), "topics": ([str],), "type": (ObservabilityPipelineKafkaSourceType,), @@ -66,8 +62,8 @@ def __init__( id: str, topics: List[str], type: ObservabilityPipelineKafkaSourceType, - librdkafka_options: Union[List[ObservabilityPipelineKafkaSourceLibrdkafkaOption], UnsetType] = unset, - sasl: Union[ObservabilityPipelineKafkaSourceSasl, UnsetType] = unset, + librdkafka_options: Union[List[ObservabilityPipelineKafkaLibrdkafkaOption], UnsetType] = unset, + sasl: Union[ObservabilityPipelineKafkaSasl, UnsetType] = unset, tls: Union[ObservabilityPipelineTls, UnsetType] = unset, **kwargs, ): @@ -81,10 +77,10 @@ def __init__( :type id: str :param librdkafka_options: Optional list of advanced Kafka client configuration options, defined as key-value pairs. - :type librdkafka_options: [ObservabilityPipelineKafkaSourceLibrdkafkaOption], optional + :type librdkafka_options: [ObservabilityPipelineKafkaLibrdkafkaOption], optional :param sasl: Specifies the SASL mechanism for authenticating with a Kafka cluster. - :type sasl: ObservabilityPipelineKafkaSourceSasl, optional + :type sasl: ObservabilityPipelineKafkaSasl, optional :param tls: Configuration for enabling TLS encryption between the pipeline component and external services. :type tls: ObservabilityPipelineTls, optional diff --git a/src/datadog_api_client/v2/models/__init__.py b/src/datadog_api_client/v2/models/__init__.py index 39ee6ab446..96cb1a009c 100644 --- a/src/datadog_api_client/v2/models/__init__.py +++ b/src/datadog_api_client/v2/models/__init__.py @@ -2924,6 +2924,12 @@ ObservabilityPipelineAmazonSecurityLakeDestinationType, ) from datadog_api_client.v2.model.observability_pipeline_aws_auth import ObservabilityPipelineAwsAuth +from datadog_api_client.v2.model.observability_pipeline_cloud_prem_destination import ( + ObservabilityPipelineCloudPremDestination, +) +from datadog_api_client.v2.model.observability_pipeline_cloud_prem_destination_type import ( + ObservabilityPipelineCloudPremDestinationType, +) from datadog_api_client.v2.model.observability_pipeline_config import ObservabilityPipelineConfig from datadog_api_client.v2.model.observability_pipeline_config_destination_item import ( ObservabilityPipelineConfigDestinationItem, @@ -3116,11 +3122,24 @@ from datadog_api_client.v2.model.observability_pipeline_http_server_source_type import ( ObservabilityPipelineHttpServerSourceType, ) -from datadog_api_client.v2.model.observability_pipeline_kafka_source import ObservabilityPipelineKafkaSource -from datadog_api_client.v2.model.observability_pipeline_kafka_source_librdkafka_option import ( - ObservabilityPipelineKafkaSourceLibrdkafkaOption, +from datadog_api_client.v2.model.observability_pipeline_kafka_destination import ObservabilityPipelineKafkaDestination +from datadog_api_client.v2.model.observability_pipeline_kafka_destination_compression import ( + ObservabilityPipelineKafkaDestinationCompression, +) +from datadog_api_client.v2.model.observability_pipeline_kafka_destination_encoding import ( + ObservabilityPipelineKafkaDestinationEncoding, +) +from datadog_api_client.v2.model.observability_pipeline_kafka_destination_type import ( + ObservabilityPipelineKafkaDestinationType, ) -from datadog_api_client.v2.model.observability_pipeline_kafka_source_sasl import ObservabilityPipelineKafkaSourceSasl +from datadog_api_client.v2.model.observability_pipeline_kafka_librdkafka_option import ( + ObservabilityPipelineKafkaLibrdkafkaOption, +) +from datadog_api_client.v2.model.observability_pipeline_kafka_sasl import ObservabilityPipelineKafkaSasl +from datadog_api_client.v2.model.observability_pipeline_kafka_sasl_mechanism import ( + ObservabilityPipelineKafkaSaslMechanism, +) +from datadog_api_client.v2.model.observability_pipeline_kafka_source import ObservabilityPipelineKafkaSource from datadog_api_client.v2.model.observability_pipeline_kafka_source_type import ObservabilityPipelineKafkaSourceType from datadog_api_client.v2.model.observability_pipeline_logstash_source import ObservabilityPipelineLogstashSource from datadog_api_client.v2.model.observability_pipeline_logstash_source_type import ( @@ -3179,9 +3198,6 @@ from datadog_api_client.v2.model.observability_pipeline_parse_json_processor_type import ( ObservabilityPipelineParseJSONProcessorType, ) -from datadog_api_client.v2.model.observability_pipeline_pipeline_kafka_source_sasl_mechanism import ( - ObservabilityPipelinePipelineKafkaSourceSaslMechanism, -) from datadog_api_client.v2.model.observability_pipeline_quota_processor import ObservabilityPipelineQuotaProcessor from datadog_api_client.v2.model.observability_pipeline_quota_processor_limit import ( ObservabilityPipelineQuotaProcessorLimit, @@ -7380,6 +7396,8 @@ "ObservabilityPipelineAmazonSecurityLakeDestination", "ObservabilityPipelineAmazonSecurityLakeDestinationType", "ObservabilityPipelineAwsAuth", + "ObservabilityPipelineCloudPremDestination", + "ObservabilityPipelineCloudPremDestinationType", "ObservabilityPipelineConfig", "ObservabilityPipelineConfigDestinationItem", "ObservabilityPipelineConfigProcessorGroup", @@ -7454,9 +7472,14 @@ "ObservabilityPipelineHttpServerSource", "ObservabilityPipelineHttpServerSourceAuthStrategy", "ObservabilityPipelineHttpServerSourceType", + "ObservabilityPipelineKafkaDestination", + "ObservabilityPipelineKafkaDestinationCompression", + "ObservabilityPipelineKafkaDestinationEncoding", + "ObservabilityPipelineKafkaDestinationType", + "ObservabilityPipelineKafkaLibrdkafkaOption", + "ObservabilityPipelineKafkaSasl", + "ObservabilityPipelineKafkaSaslMechanism", "ObservabilityPipelineKafkaSource", - "ObservabilityPipelineKafkaSourceLibrdkafkaOption", - "ObservabilityPipelineKafkaSourceSasl", "ObservabilityPipelineKafkaSourceType", "ObservabilityPipelineLogstashSource", "ObservabilityPipelineLogstashSourceType", @@ -7479,7 +7502,6 @@ "ObservabilityPipelineParseGrokProcessorType", "ObservabilityPipelineParseJSONProcessor", "ObservabilityPipelineParseJSONProcessorType", - "ObservabilityPipelinePipelineKafkaSourceSaslMechanism", "ObservabilityPipelineQuotaProcessor", "ObservabilityPipelineQuotaProcessorLimit", "ObservabilityPipelineQuotaProcessorLimitEnforceType",