KafkaAction (AWS SDK for Java

java.lang.Object
- com.amazonaws.services.iot.model.KafkaAction

All Implemented Interfaces:

StructuredPojo, Serializable, Cloneable
```
@Generated(value="com.amazonaws:aws-java-sdk-code-generator")
public class KafkaAction
extends Object
implements Serializable, Cloneable, StructuredPojo
```
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()

Constructors
Constructor and Description
`KafkaAction()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`KafkaAction`	`addClientPropertiesEntry(String key, String value)` Add a single ClientProperties entry
`KafkaAction`	`clearClientPropertiesEntries()` Removes all the entries added into ClientProperties.
`KafkaAction`	`clone()`
`boolean`	`equals(Object obj)`
`Map<String,String>`	`getClientProperties()` Properties of the Apache Kafka producer client.
`String`	`getDestinationArn()` The ARN of Kafka action's VPC `TopicRuleDestination`.
`List<KafkaActionHeader>`	`getHeaders()` The list of Kafka headers that you specify.
`String`	`getKey()` The Kafka message key.
`String`	`getPartition()` The Kafka message partition.
`String`	`getTopic()` The Kafka topic for messages to be sent to the Kafka broker.
`int`	`hashCode()`
`void`	`marshall(ProtocolMarshaller protocolMarshaller)` Marshalls this structured data using the given `ProtocolMarshaller`.
`void`	`setClientProperties(Map<String,String> clientProperties)` Properties of the Apache Kafka producer client.
`void`	`setDestinationArn(String destinationArn)` The ARN of Kafka action's VPC `TopicRuleDestination`.
`void`	`setHeaders(Collection<KafkaActionHeader> headers)` The list of Kafka headers that you specify.
`void`	`setKey(String key)` The Kafka message key.
`void`	`setPartition(String partition)` The Kafka message partition.
`void`	`setTopic(String topic)` The Kafka topic for messages to be sent to the Kafka broker.
`String`	`toString()` Returns a string representation of this object.
`KafkaAction`	`withClientProperties(Map<String,String> clientProperties)` Properties of the Apache Kafka producer client.
`KafkaAction`	`withDestinationArn(String destinationArn)` The ARN of Kafka action's VPC `TopicRuleDestination`.
`KafkaAction`	`withHeaders(Collection<KafkaActionHeader> headers)` The list of Kafka headers that you specify.
`KafkaAction`	`withHeaders(KafkaActionHeader... headers)` The list of Kafka headers that you specify.
`KafkaAction`	`withKey(String key)` The Kafka message key.
`KafkaAction`	`withPartition(String partition)` The Kafka message partition.
`KafkaAction`	`withTopic(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
  - setDestinationArn
```
public void setDestinationArn(String destinationArn)
```
    The ARN of Kafka action's VPC TopicRuleDestination.
    
    Parameters:
    
    destinationArn - The ARN of Kafka action's VPC TopicRuleDestination.
  - getDestinationArn
```
public String getDestinationArn()
```
    The ARN of Kafka action's VPC TopicRuleDestination.
    
    Returns:
    
    The ARN of Kafka action's VPC TopicRuleDestination.
  - withDestinationArn
```
public KafkaAction withDestinationArn(String destinationArn)
```
    The ARN of Kafka action's VPC TopicRuleDestination.
    
    Parameters:
    
    destinationArn - The ARN of Kafka action's VPC TopicRuleDestination.
    
    Returns:
    
    Returns a reference to this object so that method calls can be chained together.
  - setTopic
```
public void setTopic(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.
  - getTopic
```
public 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.
  - withTopic
```
public KafkaAction withTopic(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.
    
    Returns:
    
    Returns a reference to this object so that method calls can be chained together.
  - setKey
```
public void setKey(String key)
```
    The Kafka message key.
    
    Parameters:
    
    key - The Kafka message key.
  - getKey
```
public String getKey()
```
    The Kafka message key.
    
    Returns:
    
    The Kafka message key.
  - withKey
```
public KafkaAction withKey(String key)
```
    The Kafka message key.
    
    Parameters:
    
    key - The Kafka message key.
    
    Returns:
    
    Returns a reference to this object so that method calls can be chained together.
  - setPartition
```
public void setPartition(String partition)
```
    The Kafka message partition.
    
    Parameters:
    
    partition - The Kafka message partition.
  - getPartition
```
public String getPartition()
```
    The Kafka message partition.
    
    Returns:
    
    The Kafka message partition.
  - withPartition
```
public KafkaAction withPartition(String partition)
```
    The Kafka message partition.
    
    Parameters:
    
    partition - The Kafka message partition.
    
    Returns:
    
    Returns a reference to this object so that method calls can be chained together.
  - getClientProperties
```
public Map<String,String> getClientProperties()
```
    Properties of the Apache Kafka producer client.
    
    Returns:
    
    Properties of the Apache Kafka producer client.
  - setClientProperties
```
public void setClientProperties(Map<String,String> clientProperties)
```
    Properties of the Apache Kafka producer client.
    
    Parameters:
    
    clientProperties - Properties of the Apache Kafka producer client.
  - withClientProperties
```
public KafkaAction withClientProperties(Map<String,String> clientProperties)
```
    Properties of the Apache Kafka producer client.
    
    Parameters:
    
    clientProperties - Properties of the Apache Kafka producer client.
    
    Returns:
    
    Returns a reference to this object so that method calls can be chained together.
  - addClientPropertiesEntry
```
public KafkaAction addClientPropertiesEntry(String key,
                                            String value)
```
    Add a single ClientProperties entry
    
    See Also:
    
    withClientProperties(java.util.Map<java.lang.String, java.lang.String>)
  - clearClientPropertiesEntries
```
public KafkaAction clearClientPropertiesEntries()
```
    Removes all the entries added into ClientProperties.
    
    Returns:
    
    Returns a reference to this object so that method calls can be chained together.
  - getHeaders
```
public List<KafkaActionHeader> getHeaders()
```
    The list of Kafka headers that you specify.
    
    Returns:
    
    The list of Kafka headers that you specify.
  - setHeaders
```
public void setHeaders(Collection<KafkaActionHeader> headers)
```
    The list of Kafka headers that you specify.
    
    Parameters:
    
    headers - The list of Kafka headers that you specify.
  - withHeaders
```
public KafkaAction withHeaders(KafkaActionHeader... headers)
```
    The list of Kafka headers that you specify.
    
    NOTE: This method appends the values to the existing list (if any). Use setHeaders(java.util.Collection) or withHeaders(java.util.Collection) if you want to override the existing values.
    
    Parameters:
    
    headers - The list of Kafka headers that you specify.
    
    Returns:
    
    Returns a reference to this object so that method calls can be chained together.
  - withHeaders
```
public KafkaAction withHeaders(Collection<KafkaActionHeader> headers)
```
    The list of Kafka headers that you specify.
    
    Parameters:
    
    headers - The list of Kafka headers that you specify.
    
    Returns:
    
    Returns a reference to this object so that method calls can be chained together.
  - toString
```
public String toString()
```
    Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be redacted from this string using a placeholder value.
    
    Overrides:
    
    toString in class Object
    
    Returns:
    
    A string representation of this object.
    
    See Also:
    
    Object.toString()
  - equals
```
public boolean equals(Object obj)
```
    Overrides:
    
    equals in class Object
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class Object
  - clone
```
public KafkaAction clone()
```
    Overrides:
    
    clone in class Object
  - marshall
```
public void marshall(ProtocolMarshaller protocolMarshaller)
```
    Description copied from interface: StructuredPojo
    
    Marshalls this structured data using the given ProtocolMarshaller.
    
    Specified by:
    
    marshall in interface StructuredPojo
    
    Parameters:
    
    protocolMarshaller - Implementation of ProtocolMarshaller used to marshall this object's data.

AWS SDK for Java 1.x API Reference - 1.12.773

Class KafkaAction

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

KafkaAction

Method Detail

setDestinationArn

getDestinationArn

withDestinationArn

setTopic

getTopic

withTopic

setKey

getKey

withKey

setPartition

getPartition

withPartition

getClientProperties

setClientProperties

withClientProperties

addClientPropertiesEntry

clearClientPropertiesEntries

getHeaders

setHeaders

withHeaders

withHeaders

toString

equals

hashCode

clone

marshall