Skip to content

Commit 2cd1bd5

Browse files
authored
Add revapi breaking change justifications for KafkaConsumer and KafkaConnector API changes (#3595)
1 parent 189c5c5 commit 2cd1bd5

1 file changed

Lines changed: 28 additions & 1 deletion

File tree

‎smallrye-reactive-messaging-kafka/revapi.json‎

Lines changed: 28 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,34 @@
3636
"criticality" : "highlight",
3737
"minSeverity" : "POTENTIALLY_BREAKING",
3838
"minCriticality" : "documented",
39-
"differences" : [ ]
39+
"differences" : [ {
40+
"code": "java.method.addedToInterface",
41+
"new": "method io.smallrye.mutiny.Uni<java.lang.Void> io.smallrye.reactive.messaging.kafka.KafkaConsumer<K, V>::pausePartitions(java.util.Collection<org.apache.kafka.common.TopicPartition>)",
42+
"justification": "Add pausePartitions method to KafkaConsumer interface"
43+
}, {
44+
"code": "java.method.addedToInterface",
45+
"new": "method java.util.Set<org.apache.kafka.common.TopicPartition> io.smallrye.reactive.messaging.kafka.KafkaConsumer<K, V>::pausedPartitions()",
46+
"justification": "Add pausedPartitions method to KafkaConsumer interface"
47+
}, {
48+
"code": "java.method.addedToInterface",
49+
"new": "method io.smallrye.mutiny.Uni<java.lang.Void> io.smallrye.reactive.messaging.kafka.KafkaConsumer<K, V>::resumePartitions(java.util.Collection<org.apache.kafka.common.TopicPartition>)",
50+
"justification": "Add resumePartitions method to KafkaConsumer interface"
51+
}, {
52+
"code": "java.method.addedToInterface",
53+
"new": "method io.smallrye.mutiny.Uni<java.lang.Void> io.smallrye.reactive.messaging.kafka.KafkaConsumer<K, V>::pauseAssignedPartitions()",
54+
"justification": "Add pauseAssignedPartitions method to KafkaConsumer interface"
55+
}, {
56+
"code": "java.annotation.attributeValueChanged",
57+
"old": "class io.smallrye.reactive.messaging.kafka.KafkaConnector",
58+
"new": "class io.smallrye.reactive.messaging.kafka.KafkaConnector",
59+
"annotationType": "io.smallrye.reactive.messaging.annotations.ConnectorAttributes",
60+
"attribute": "value",
61+
"justification": "Rename retries to send.retries outgoing attribute"
62+
}, {
63+
"code": "java.method.removed",
64+
"old": "method java.lang.Long io.smallrye.reactive.messaging.kafka.KafkaConnectorOutgoingConfiguration::getRetries()",
65+
"justification": "Rename retries to send.retries outgoing attribute"
66+
} ]
4067
}
4168
}, {
4269
"extension" : "revapi.reporter.json",

0 commit comments

Comments
 (0)