Skip to content

Commit 1ff7823

Browse files
committed
Remove unused method
1 parent f60a554 commit 1ff7823

File tree

1 file changed

+0
-19
lines changed

1 file changed

+0
-19
lines changed

spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -585,25 +585,6 @@ private List<TopicPartitionOffset> resolveTopicPartitionsList(TopicPartition top
585585
return result;
586586
}
587587

588-
private Integer resolvePartition(Object topic, PartitionOffset partitionOffset) {
589-
Object partitionValue = resolveExpression(partitionOffset.partition());
590-
Integer partition;
591-
if (partitionValue instanceof String) {
592-
Assert.state(StringUtils.hasText((String) partitionValue),
593-
() -> "partition in @PartitionOffset for topic '" + topic + "' cannot be empty");
594-
partition = Integer.valueOf((String) partitionValue);
595-
}
596-
else if (partitionValue instanceof Integer) {
597-
partition = (Integer) partitionValue;
598-
}
599-
else {
600-
throw new IllegalArgumentException(String.format(
601-
"@PartitionOffset for topic '%s' can't resolve '%s' as an Integer or String, resolved to '%s'",
602-
topic, partitionOffset.partition(), partitionValue.getClass()));
603-
}
604-
return partition;
605-
}
606-
607588
private Long resolveInitialOffset(Object topic, PartitionOffset partitionOffset) {
608589
Object initialOffsetValue = resolveExpression(partitionOffset.initialOffset());
609590
Long initialOffset;

0 commit comments

Comments
 (0)