diff --git a/src/main/java/io/strimzi/kafka/bridge/SinkTopicSubscription.java b/src/main/java/io/strimzi/kafka/bridge/SinkTopicSubscription.java index 2323e74b..ba383e4e 100644 --- a/src/main/java/io/strimzi/kafka/bridge/SinkTopicSubscription.java +++ b/src/main/java/io/strimzi/kafka/bridge/SinkTopicSubscription.java @@ -11,8 +11,8 @@ */ public class SinkTopicSubscription { - private String topic; - private Integer partition; + private final String topic; + private final Integer partition; /** * Constructor @@ -41,15 +41,6 @@ public String getTopic() { return topic; } - /** - * Set the topic to subscribe/assign - * - * @param topic topic to subscribe/assign - */ - public void setTopic(String topic) { - this.topic = topic; - } - /** * @return partition requested as assignment (null if no specific assignment) */ @@ -57,15 +48,6 @@ public Integer getPartition() { return partition; } - /** - * Set the partition requested as assignment (null if no specific assignment) - * - * @param partition partition requested as assignment (null if no specific assignment) - */ - public void setPartition(Integer partition) { - this.partition = partition; - } - @Override public String toString() { return "SinkTopicSubscription(" +