chia7712 commented on code in PR #22993:
URL: https://github.com/apache/kafka/pull/22993#discussion_r3728792644
##########
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KStreamRepartitionIntegrationTest.java:
##########
@@ -335,8 +336,28 @@ public void shouldRepartitionToMultiplePartitions(final
String topologyOptimizat
final List<KeyValue<Integer, String>> expectedRecords =
expectedRecordsOnRepartition.subList(3, 5);
class BroadcastingPartitioner implements StreamPartitioner<Integer,
String> {
+ @SuppressWarnings("removal")
@Override
- public Optional<Set<Integer>> partitions(final String topic, final
Integer key, final String value, final int numPartitions) {
+ public Optional<Set<Integer>> partitions(
Review Comment:
Maybe we could just add `@SuppressWarnings("removal")`. The deprecated code
will be cleaned up eventually in 5.0
--
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]
