Моя конечная цель состоит в том, чтобы найти количество разделов по теме пульсар (получение количества разделов пульсной темы: нельзя было разобраться в правильном URI, отсутствующую схему), но в процессе альтернативного метода, столкнувшись с чем -то ощутимым. случается. < /p>
for (i in 0..MAX_NUM_PARTITIONS) {
val topicPartition = "$topic-partition-$i"
var partitionReader: Reader? = null
try {
partitionReader =
client
.newReader(BYTES)
.startMessageId(MessageId.latest)
.topic(topicPartition)
.create()
} catch (e: Exception) {
// TODO: This still prints a CompletionException error to the console unnecessarily.
// Either catch that or calculate # partitions in a cleaner way.
break
}
if (partitionReader != null) {
readers.add(partitionReader)
}
}
< /code>
Java.Util.concurrent.complationException:
орг.apache.pulsar.client.api.pulsarClientException $ Поймайте исключение и не печатайте в консоли. OpplionException я не хочу печатать.>
Подробнее здесь: https://stackoverflow.com/questions/792 ... n-function
