Package com.datadog.api.client.v2.model

Class ObservabilityPipelineKafkaSource

java.lang.Object

com.datadog.api.client.v2.model.ObservabilityPipelineKafkaSource

@Generated("https://github.com/DataDog/datadog-api-client-java/blob/master/.generator")
public class ObservabilityPipelineKafkaSource
extends Object

The kafka source ingests data from Apache Kafka topics.

Supported pipeline types: logs

Field Summary

Fields

Modifier and Type	Field	Description
static final String	JSON_PROPERTY_BOOTSTRAP_SERVERS_KEY
static final String	JSON_PROPERTY_GROUP_ID
static final String	JSON_PROPERTY_ID
static final String	JSON_PROPERTY_LIBRDKAFKA_OPTIONS
static final String	JSON_PROPERTY_SASL
static final String	JSON_PROPERTY_TLS
static final String	JSON_PROPERTY_TOPICS
static final String	JSON_PROPERTY_TYPE
boolean	unparsed

Constructor Summary

Constructors

Constructor	Description
ObservabilityPipelineKafkaSource()
ObservabilityPipelineKafkaSource(String groupId, String id, List<String> topics, ObservabilityPipelineKafkaSourceType type)

Method Summary

Modifier and Type	Method	Description
ObservabilityPipelineKafkaSource	addLibrdkafkaOptionsItem(ObservabilityPipelineKafkaLibrdkafkaOption librdkafkaOptionsItem)
ObservabilityPipelineKafkaSource	addTopicsItem(String topicsItem)
ObservabilityPipelineKafkaSource	bootstrapServersKey(String bootstrapServersKey)
boolean	equals(Object o)	Return true if this ObservabilityPipelineKafkaSource object is equal to o.
Map<String,Object>	getAdditionalProperties()	Return the additional (undeclared) property.
Object	getAdditionalProperty(String key)	Return the additional (undeclared) property with the specified name.
String	getBootstrapServersKey()	Name of the environment variable or secret that holds the Kafka bootstrap servers list.
String	getGroupId()	Consumer group ID used by the Kafka client.
String	getId()	The unique identifier for this component.
List<ObservabilityPipelineKafkaLibrdkafkaOption>	getLibrdkafkaOptions()	Optional list of advanced Kafka client configuration options, defined as key-value pairs.
ObservabilityPipelineKafkaSasl	getSasl()	Specifies the SASL mechanism for authenticating with a Kafka cluster.
ObservabilityPipelineTls	getTls()	Configuration for enabling TLS encryption between the pipeline component and external services.
List<String>	getTopics()	A list of Kafka topic names to subscribe to.
ObservabilityPipelineKafkaSourceType	getType()	The source type.
ObservabilityPipelineKafkaSource	groupId(String groupId)
int	hashCode()
ObservabilityPipelineKafkaSource	id(String id)
ObservabilityPipelineKafkaSource	librdkafkaOptions(List<ObservabilityPipelineKafkaLibrdkafkaOption> librdkafkaOptions)
ObservabilityPipelineKafkaSource	putAdditionalProperty(String key, Object value)	Set the additional (undeclared) property with the specified name and value.
ObservabilityPipelineKafkaSource	sasl(ObservabilityPipelineKafkaSasl sasl)
void	setBootstrapServersKey(String bootstrapServersKey)
void	setGroupId(String groupId)
void	setId(String id)
void	setLibrdkafkaOptions(List<ObservabilityPipelineKafkaLibrdkafkaOption> librdkafkaOptions)
void	setSasl(ObservabilityPipelineKafkaSasl sasl)
void	setTls(ObservabilityPipelineTls tls)
void	setTopics(List<String> topics)
void	setType(ObservabilityPipelineKafkaSourceType type)
ObservabilityPipelineKafkaSource	tls(ObservabilityPipelineTls tls)
ObservabilityPipelineKafkaSource	topics(List<String> topics)
String	toString()
ObservabilityPipelineKafkaSource	type(ObservabilityPipelineKafkaSourceType type)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

unparsed

public boolean unparsed

JSON_PROPERTY_BOOTSTRAP_SERVERS_KEY

public static final String JSON_PROPERTY_BOOTSTRAP_SERVERS_KEY

See Also:

• Constant Field Values

JSON_PROPERTY_GROUP_ID

public static final String JSON_PROPERTY_GROUP_ID

See Also:

• Constant Field Values

JSON_PROPERTY_ID

public static final String JSON_PROPERTY_ID

See Also:

• Constant Field Values

JSON_PROPERTY_LIBRDKAFKA_OPTIONS

public static final String JSON_PROPERTY_LIBRDKAFKA_OPTIONS

See Also:

• Constant Field Values

JSON_PROPERTY_SASL

public static final String JSON_PROPERTY_SASL

See Also:

• Constant Field Values

JSON_PROPERTY_TLS

public static final String JSON_PROPERTY_TLS

See Also:

• Constant Field Values

JSON_PROPERTY_TOPICS

public static final String JSON_PROPERTY_TOPICS

See Also:

• Constant Field Values

JSON_PROPERTY_TYPE

public static final String JSON_PROPERTY_TYPE

See Also:

• Constant Field Values

Constructor Details

ObservabilityPipelineKafkaSource

public ObservabilityPipelineKafkaSource()

ObservabilityPipelineKafkaSource

public ObservabilityPipelineKafkaSource(String groupId,
 String id,
 List<String> topics,
 ObservabilityPipelineKafkaSourceType type)

Method Details

bootstrapServersKey

public ObservabilityPipelineKafkaSource bootstrapServersKey(String bootstrapServersKey)

getBootstrapServersKey

@Nullable
public String getBootstrapServersKey()

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

Returns:

bootstrapServersKey

setBootstrapServersKey

public void setBootstrapServersKey(String bootstrapServersKey)

groupId

public ObservabilityPipelineKafkaSource groupId(String groupId)

getGroupId

public String getGroupId()

Consumer group ID used by the Kafka client.

Returns:

groupId

setGroupId

public void setGroupId(String groupId)

id

public ObservabilityPipelineKafkaSource id(String id)

getId

public String getId()

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).

Returns:

id

setId

public void setId(String id)

librdkafkaOptions

public ObservabilityPipelineKafkaSource librdkafkaOptions(List<ObservabilityPipelineKafkaLibrdkafkaOption> librdkafkaOptions)

addLibrdkafkaOptionsItem

public ObservabilityPipelineKafkaSource addLibrdkafkaOptionsItem(ObservabilityPipelineKafkaLibrdkafkaOption librdkafkaOptionsItem)

getLibrdkafkaOptions

@Nullable
public List<ObservabilityPipelineKafkaLibrdkafkaOption> getLibrdkafkaOptions()

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

Returns:

librdkafkaOptions

setLibrdkafkaOptions

public void setLibrdkafkaOptions(List<ObservabilityPipelineKafkaLibrdkafkaOption> librdkafkaOptions)

sasl

public ObservabilityPipelineKafkaSource sasl(ObservabilityPipelineKafkaSasl sasl)

getSasl

@Nullable
public ObservabilityPipelineKafkaSasl getSasl()

Specifies the SASL mechanism for authenticating with a Kafka cluster.

Returns:

sasl

setSasl

public void setSasl(ObservabilityPipelineKafkaSasl sasl)

tls

public ObservabilityPipelineKafkaSource tls(ObservabilityPipelineTls tls)

getTls

@Nullable
public ObservabilityPipelineTls getTls()

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

Returns:

tls

setTls

public void setTls(ObservabilityPipelineTls tls)

topics

public ObservabilityPipelineKafkaSource topics(List<String> topics)

addTopicsItem

public ObservabilityPipelineKafkaSource addTopicsItem(String topicsItem)

getTopics

public List<String> getTopics()

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

Returns:

topics

setTopics

public void setTopics(List<String> topics)

type

public ObservabilityPipelineKafkaSource type(ObservabilityPipelineKafkaSourceType type)

getType

public ObservabilityPipelineKafkaSourceType getType()

The source type. The value should always be kafka.

Returns:

type

setType

public void setType(ObservabilityPipelineKafkaSourceType type)

putAdditionalProperty

public ObservabilityPipelineKafkaSource putAdditionalProperty(String key,
 Object value)

Set the additional (undeclared) property with the specified name and value. If the property does not already exist, create it otherwise replace it.

Parameters:

key - The arbitrary key to set

value - The associated value

Returns:

ObservabilityPipelineKafkaSource

getAdditionalProperties

public Map<String,Object> getAdditionalProperties()

Return the additional (undeclared) property.

Returns:

The additional properties

getAdditionalProperty

public Object getAdditionalProperty(String key)

Return the additional (undeclared) property with the specified name.

Parameters:

key - The arbitrary key to get

Returns:

The specific additional property for the given key

equals

public boolean equals(Object o)

Return true if this ObservabilityPipelineKafkaSource object is equal to o.

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object