Class: DatadogAPIClient::V2::ObservabilityPipelineKafkaSource

Inherits:
Object
  • Object
show all
Includes:
BaseGenericModel
Defined in:
lib/datadog_api_client/v2/models/observability_pipeline_kafka_source.rb

Overview

The kafka source ingests data from Apache Kafka topics.

**Supported pipeline types:** logs

Instance Attribute Summary collapse

Method Summary

Methods included from BaseGenericModel

included

Instance Attribute Details

#additional_properties ⇒ Object

Returns the value of attribute additional_properties.



50
51
52
 
# File 'lib/datadog_api_client/v2/models/observability_pipeline_kafka_source.rb', line 50

def additional_properties
  @additional_properties
end

#bootstrap_servers_key ⇒ Object

Name of the environment variable or secret that holds the Kafka bootstrap servers list.



27
28
29
 
# File 'lib/datadog_api_client/v2/models/observability_pipeline_kafka_source.rb', line 27

def bootstrap_servers_key
  @bootstrap_servers_key
end

#group_id ⇒ Object

Consumer group ID used by the Kafka client.



30
31
32
 
# File 'lib/datadog_api_client/v2/models/observability_pipeline_kafka_source.rb', line 30

def group_id
  @group_id
end

#id ⇒ Object

The unique identifier for this component. Used in other parts of the pipeline to reference this component (for example, as the input to downstream components).



33
34
35
 
# File 'lib/datadog_api_client/v2/models/observability_pipeline_kafka_source.rb', line 33

def id
  @id
end

#librdkafka_options ⇒ Object

Optional list of advanced Kafka client configuration options, defined as key-value pairs.



36
37
38
 
# File 'lib/datadog_api_client/v2/models/observability_pipeline_kafka_source.rb', line 36

def librdkafka_options
  @librdkafka_options
end

#sasl ⇒ Object

Specifies the SASL mechanism for authenticating with a Kafka cluster.



39
40
41
 
# File 'lib/datadog_api_client/v2/models/observability_pipeline_kafka_source.rb', line 39

def sasl
  @sasl
end

#tls ⇒ Object

Configuration for enabling TLS encryption between the pipeline component and external services.



42
43
44
 
# File 'lib/datadog_api_client/v2/models/observability_pipeline_kafka_source.rb', line 42

def tls
  @tls
end

#topics ⇒ Object

A list of Kafka topic names to subscribe to. The source ingests messages from each topic specified.



45
46
47
 
# File 'lib/datadog_api_client/v2/models/observability_pipeline_kafka_source.rb', line 45

def topics
  @topics
end

#type ⇒ Object

The source type. The value should always be kafka.



48
49
50
 
# File 'lib/datadog_api_client/v2/models/observability_pipeline_kafka_source.rb', line 48

def type
  @type
end