kafka.clients.consumer.KafkaConsumer has method listTopics() which has a timeout. /** * Get metadata about partitions for all topics that the ...
確定! 回上一頁