public class PulsarLogCollectClient extends org.apache.shenyu.plugin.logging.common.client.AbstractLogConsumeClient<PulsarLogCollectConfig.PulsarLogConfig,org.apache.shenyu.plugin.logging.common.entity.ShenyuRequestLog>
| 构造器和说明 |
|---|
PulsarLogCollectClient() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
close0() |
void |
consume0(java.util.List<org.apache.shenyu.plugin.logging.common.entity.ShenyuRequestLog> logs) |
void |
initClient0(PulsarLogCollectConfig.PulsarLogConfig config)
init producer.
|
public void initClient0(@NonNull
PulsarLogCollectConfig.PulsarLogConfig config)
initClient0 在类中 org.apache.shenyu.plugin.logging.common.client.AbstractLogConsumeClient<PulsarLogCollectConfig.PulsarLogConfig,org.apache.shenyu.plugin.logging.common.entity.ShenyuRequestLog>config - pulsar propspublic void consume0(@NonNull
java.util.List<org.apache.shenyu.plugin.logging.common.entity.ShenyuRequestLog> logs)
consume0 在类中 org.apache.shenyu.plugin.logging.common.client.AbstractLogConsumeClient<PulsarLogCollectConfig.PulsarLogConfig,org.apache.shenyu.plugin.logging.common.entity.ShenyuRequestLog>public void close0()
close0 在类中 org.apache.shenyu.plugin.logging.common.client.AbstractLogConsumeClient<PulsarLogCollectConfig.PulsarLogConfig,org.apache.shenyu.plugin.logging.common.entity.ShenyuRequestLog>Copyright © 2026 The Apache Software Foundation. All rights reserved.