pulsar producers 例子

Pulsar Producers 例子

import java.util.concurrent.TimeUnit; import org.apache.pulsar.client.api.Producer; import org.apac