@ConfigurationProperties(prefix="spring.batch.job.kafkaitemwriter") public class KafkaItemWriterProperties extends Object
KafkaItemWriter.| Constructor and Description |
|---|
KafkaItemWriterProperties() |
| Modifier and Type | Method and Description |
|---|---|
String |
getTopic()
Returns the name of the topic from which messages will be written.
|
boolean |
isDelete()
Indicate if the items being passed to the writer are all to be sent as delete
events to the topic.
|
void |
setDelete(boolean delete)
Indicate if the items being passed to the writer are all to be sent as delete
events to the topic.
|
void |
setTopic(String topic)
The topic name from which the messages will be read.
|
public String getTopic()
public void setTopic(String topic)
topic - name of the topicpublic boolean isDelete()
public void setDelete(boolean delete)
delete - removal indicator.Copyright © 2021 Pivotal Software, Inc.. All rights reserved.