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