com.amazonaws.services.iot.model

Class KafkaAction

java.lang.Object

com.amazonaws.services.iot.model.KafkaAction

All Implemented Interfaces:

java.io.Serializable

public class KafkaAction
extends java.lang.Object
implements java.io.Serializable

Send messages to an Amazon Managed Streaming for Apache Kafka (Amazon MSK) or self-managed Apache Kafka cluster.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KafkaAction()

Method Summary

Modifier and Type	Method and Description
KafkaAction	addclientPropertiesEntry(java.lang.String key, java.lang.String value) Properties of the Apache Kafka producer client.
KafkaAction	clearclientPropertiesEntries() Removes all the entries added into clientProperties.
boolean	equals(java.lang.Object obj)
java.util.Map<java.lang.String,java.lang.String>	getClientProperties() Properties of the Apache Kafka producer client.
java.lang.String	getDestinationArn() The ARN of Kafka action's VPC TopicRuleDestination.
java.lang.String	getKey() The Kafka message key.
java.lang.String	getPartition() The Kafka message partition.
java.lang.String	getTopic() The Kafka topic for messages to be sent to the Kafka broker.
int	hashCode()
void	setClientProperties(java.util.Map<java.lang.String,java.lang.String> clientProperties) Properties of the Apache Kafka producer client.
void	setDestinationArn(java.lang.String destinationArn) The ARN of Kafka action's VPC TopicRuleDestination.
void	setKey(java.lang.String key) The Kafka message key.
void	setPartition(java.lang.String partition) The Kafka message partition.
void	setTopic(java.lang.String topic) The Kafka topic for messages to be sent to the Kafka broker.
java.lang.String	toString() Returns a string representation of this object; useful for testing and debugging.
KafkaAction	withClientProperties(java.util.Map<java.lang.String,java.lang.String> clientProperties) Properties of the Apache Kafka producer client.
KafkaAction	withDestinationArn(java.lang.String destinationArn) The ARN of Kafka action's VPC TopicRuleDestination.
KafkaAction	withKey(java.lang.String key) The Kafka message key.
KafkaAction	withPartition(java.lang.String partition) The Kafka message partition.
KafkaAction	withTopic(java.lang.String topic) The Kafka topic for messages to be sent to the Kafka broker.

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

KafkaAction

public KafkaAction()

Method Detail

getDestinationArn

public java.lang.String getDestinationArn()

The ARN of Kafka action's VPC TopicRuleDestination.

Returns:

The ARN of Kafka action's VPC TopicRuleDestination.

setDestinationArn

public void setDestinationArn(java.lang.String destinationArn)

The ARN of Kafka action's VPC TopicRuleDestination.

Parameters:

destinationArn -

The ARN of Kafka action's VPC TopicRuleDestination.

withDestinationArn

public KafkaAction withDestinationArn(java.lang.String destinationArn)

The ARN of Kafka action's VPC TopicRuleDestination.

Returns a reference to this object so that method calls can be chained together.

Parameters:

destinationArn -

The ARN of Kafka action's VPC TopicRuleDestination.

Returns:

A reference to this updated object so that method calls can be chained together.

getTopic

public java.lang.String getTopic()

The Kafka topic for messages to be sent to the Kafka broker.

Returns:

The Kafka topic for messages to be sent to the Kafka broker.

setTopic

public void setTopic(java.lang.String topic)

The Kafka topic for messages to be sent to the Kafka broker.

Parameters:

topic -

The Kafka topic for messages to be sent to the Kafka broker.

withTopic

public KafkaAction withTopic(java.lang.String topic)

The Kafka topic for messages to be sent to the Kafka broker.

Returns a reference to this object so that method calls can be chained together.

Parameters:

topic -

The Kafka topic for messages to be sent to the Kafka broker.

Returns:

A reference to this updated object so that method calls can be chained together.

getKey

public java.lang.String getKey()

The Kafka message key.

Returns:

The Kafka message key.

setKey

public void setKey(java.lang.String key)

The Kafka message key.

Parameters:

key -

The Kafka message key.

withKey

public KafkaAction withKey(java.lang.String key)

The Kafka message key.

Returns a reference to this object so that method calls can be chained together.

Parameters:

key -

The Kafka message key.

Returns:

A reference to this updated object so that method calls can be chained together.

getPartition

public java.lang.String getPartition()

The Kafka message partition.

Returns:

The Kafka message partition.

setPartition

public void setPartition(java.lang.String partition)

The Kafka message partition.

Parameters:

partition -

The Kafka message partition.

withPartition

public KafkaAction withPartition(java.lang.String partition)

The Kafka message partition.

Returns a reference to this object so that method calls can be chained together.

Parameters:

partition -

The Kafka message partition.

Returns:

A reference to this updated object so that method calls can be chained together.

getClientProperties

public java.util.Map<java.lang.String,java.lang.String> getClientProperties()

Properties of the Apache Kafka producer client.

Returns:

Properties of the Apache Kafka producer client.

setClientProperties

public void setClientProperties(java.util.Map<java.lang.String,java.lang.String> clientProperties)

Properties of the Apache Kafka producer client.

Parameters:

clientProperties -

Properties of the Apache Kafka producer client.

withClientProperties

public KafkaAction withClientProperties(java.util.Map<java.lang.String,java.lang.String> clientProperties)

Properties of the Apache Kafka producer client.

Returns a reference to this object so that method calls can be chained together.

Parameters:

clientProperties -

Properties of the Apache Kafka producer client.

Returns:

A reference to this updated object so that method calls can be chained together.

addclientPropertiesEntry

public KafkaAction addclientPropertiesEntry(java.lang.String key,
                                            java.lang.String value)

Properties of the Apache Kafka producer client.

The method adds a new key-value pair into clientProperties parameter, and returns a reference to this object so that method calls can be chained together.

Parameters:

key - The key of the entry to be added into clientProperties.

value - The corresponding value of the entry to be added into clientProperties.

Returns:

A reference to this updated object so that method calls can be chained together.

clearclientPropertiesEntries

public KafkaAction clearclientPropertiesEntries()

Removes all the entries added into clientProperties.

Returns a reference to this object so that method calls can be chained together.

toString

public java.lang.String toString()

Returns a string representation of this object; useful for testing and debugging.

Overrides:

toString in class java.lang.Object

Returns:

A string representation of this object.

See Also:

Object.toString()

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object