dino2895 commented on code in PR #22993:
URL: https://github.com/apache/kafka/pull/22993#discussion_r3734653362
##########
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:
Thanks. I followed #22570 to use the 5-argument overload, but I missed that
the old one will be removed in 5.0. I’ll simplify it.
--
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]
