nizhikov commented on a change in pull request #99:
URL: https://github.com/apache/ignite-extensions/pull/99#discussion_r816129064
##########
File path:
modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/IgniteToKafkaCdcStreamer.java
##########
@@ -232,4 +225,123 @@ public IgniteToKafkaCdcStreamer(
@Override public void stop() {
producer.close();
}
+
+ /** @return Whether entries only from primary nodes should be handled. */
+ public boolean isOnlyPrimary() {
+ return onlyPrimary;
+ }
+
+ /**
+ * Sets whether entries only from primary nodes should be handled.
+ *
+ * @param onlyPrimary Kafka whether entries only from primary nodes should
be handled.
+ * @return {@code this} for chaining.
+ */
+ public IgniteToKafkaCdcStreamer setOnlyPrimary(boolean onlyPrimary) {
+ this.onlyPrimary = onlyPrimary;
+
+ return this;
+ }
+
+ /** @return Topic that is used to send data to Kafka. */
+ public String getTopic() {
+ return topic;
+ }
+
+ /**
+ * Sets topic that is used to send data to Kafka.
+ *
+ * @param topic Kafka topic.
+ * @return {@code this} for chaining.
+ */
+ public IgniteToKafkaCdcStreamer setTopic(String topic) {
+ this.topic = topic;
+
+ return this;
+ }
+
+ /** @return Number of Kafka partitions. */
+ public int getKafkaPartitions() {
+ return kafkaParts;
+ }
+
+ /**
+ * Sets number of Kafka partitions.
+ *
+ * @param kafkaParts Number of Kafka partitions.
+ * @return {@code this} for chaining.
+ */
+ public IgniteToKafkaCdcStreamer setKafkaPartitions(int kafkaParts) {
+ this.kafkaParts = kafkaParts;
+
+ return this;
+ }
+
+ /** @return Cache names that participate in CDC. */
+ public Collection<String> getCaches() {
Review comment:
Can we get rid of all getters?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
