@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class SelfManagedEventSource extends Object implements Serializable, Cloneable, StructuredPojo
The self-managed Apache Kafka cluster for your event source.
Constructor and Description |
---|
SelfManagedEventSource() |
Modifier and Type | Method and Description |
---|---|
SelfManagedEventSource |
addEndpointsEntry(String key,
List<String> value)
Add a single Endpoints entry
|
SelfManagedEventSource |
clearEndpointsEntries()
Removes all the entries added into Endpoints.
|
SelfManagedEventSource |
clone() |
boolean |
equals(Object obj) |
Map<String,List<String>> |
getEndpoints()
The list of bootstrap servers for your Kafka brokers in the following format:
"KAFKA_BOOTSTRAP_SERVERS": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"] . |
int |
hashCode() |
void |
marshall(ProtocolMarshaller protocolMarshaller)
Marshalls this structured data using the given
ProtocolMarshaller . |
void |
setEndpoints(Map<String,List<String>> endpoints)
The list of bootstrap servers for your Kafka brokers in the following format:
"KAFKA_BOOTSTRAP_SERVERS": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"] . |
String |
toString()
Returns a string representation of this object.
|
SelfManagedEventSource |
withEndpoints(Map<String,List<String>> endpoints)
The list of bootstrap servers for your Kafka brokers in the following format:
"KAFKA_BOOTSTRAP_SERVERS": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"] . |
public Map<String,List<String>> getEndpoints()
The list of bootstrap servers for your Kafka brokers in the following format:
"KAFKA_BOOTSTRAP_SERVERS": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"]
.
"KAFKA_BOOTSTRAP_SERVERS": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"]
.public void setEndpoints(Map<String,List<String>> endpoints)
The list of bootstrap servers for your Kafka brokers in the following format:
"KAFKA_BOOTSTRAP_SERVERS": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"]
.
endpoints
- The list of bootstrap servers for your Kafka brokers in the following format:
"KAFKA_BOOTSTRAP_SERVERS": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"]
.public SelfManagedEventSource withEndpoints(Map<String,List<String>> endpoints)
The list of bootstrap servers for your Kafka brokers in the following format:
"KAFKA_BOOTSTRAP_SERVERS": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"]
.
endpoints
- The list of bootstrap servers for your Kafka brokers in the following format:
"KAFKA_BOOTSTRAP_SERVERS": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"]
.public SelfManagedEventSource addEndpointsEntry(String key, List<String> value)
public SelfManagedEventSource clearEndpointsEntries()
public String toString()
toString
in class Object
Object.toString()
public SelfManagedEventSource clone()
public void marshall(ProtocolMarshaller protocolMarshaller)
StructuredPojo
ProtocolMarshaller
.marshall
in interface StructuredPojo
protocolMarshaller
- Implementation of ProtocolMarshaller
used to marshall this object's data.