索引

A B C D E G H I K M N O P R S T U V
All Classes and Interfaces|常量字段值|所有程序包|序列化表格

A

AbstractExecutorKafkaConsumer<K,V> - io.github.wooenrico.kafka.consumer中的类

AbstractExecutorKafkaConsumer(String, ExecutorConsumerProperties, Deserializer<K>, Deserializer<V>, ConsumerRebalanceListener) - 类的构造器 io.github.wooenrico.kafka.consumer.AbstractExecutorKafkaConsumer

AbstractExecutorKafkaReceiver<K,V> - io.github.wooenrico.kafka.consumer中的类

AbstractExecutorKafkaReceiver(String, ExecutorConsumerProperties, Deserializer<K>, Deserializer<V>, Consumer<Collection<ReceiverPartition>>, Consumer<Collection<ReceiverPartition>>) - 类的构造器 io.github.wooenrico.kafka.consumer.AbstractExecutorKafkaReceiver

AbstractKafkaConsumer<K,V> - io.github.wooenrico.kafka.consumer中的类

AbstractKafkaConsumer(String, ConsumerProperties, Deserializer<K>, Deserializer<V>, ConsumerRebalanceListener) - 类的构造器 io.github.wooenrico.kafka.consumer.AbstractKafkaConsumer

AbstractKafkaReceiver<K,V> - io.github.wooenrico.kafka.consumer中的类

AbstractKafkaReceiver(String, ConsumerProperties, Deserializer<K>, Deserializer<V>, Consumer<Collection<ReceiverPartition>>, Consumer<Collection<ReceiverPartition>>) - 类的构造器 io.github.wooenrico.kafka.consumer.AbstractKafkaReceiver

AbstractRateLimitExecutorKafkaConsumer<K,V> - io.github.wooenrico.kafka.consumer中的类

AbstractRateLimitExecutorKafkaConsumer(String, RateLimitExecutorConsumerProperties, Deserializer<K>, Deserializer<V>, ConsumerRebalanceListener) - 类的构造器 io.github.wooenrico.kafka.consumer.AbstractRateLimitExecutorKafkaConsumer

AbstractRateLimitExecutorKafkaReceiver<K,V> - io.github.wooenrico.kafka.consumer中的类

AbstractRateLimitExecutorKafkaReceiver(String, RateLimitExecutorConsumerProperties, Deserializer<K>, Deserializer<V>, Consumer<Collection<ReceiverPartition>>, Consumer<Collection<ReceiverPartition>>) - 类的构造器 io.github.wooenrico.kafka.consumer.AbstractRateLimitExecutorKafkaReceiver

addCommonProperties(Properties) - 类中的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

addCommonProperties(Properties) - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

addProperties(String, Object) - 类中的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

addProperties(String, Object) - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

afterPropertiesSet() - 类中的方法 io.github.wooenrico.kafka.consumer.KafkaConsumerFactory

afterSingletonsInstantiated() - 类中的方法 io.github.wooenrico.kafka.consumer.KafkaConsumerFactory

AutoKafka - io.github.wooenrico.kafka.annotation中的Annotation Interface

AutoKafkaConfiguration - io.github.wooenrico.kafka.configuration中的类

AutoKafkaConfiguration() - 类的构造器 io.github.wooenrico.kafka.configuration.AutoKafkaConfiguration

B

BeanNameRateLimitExecutorConsumerProperties - io.github.wooenrico.kafka中的类

指定handler bean name的速率限制线程池消费者配置

BeanNameRateLimitExecutorConsumerProperties() - 类的构造器 io.github.wooenrico.kafka.BeanNameRateLimitExecutorConsumerProperties

body(byte[]) - 类中的方法 io.github.wooenrico.http.common.HttpRequestBuilder

Sets the body for the HttpRequest.

build() - 类中的方法 io.github.wooenrico.http.common.HttpRequestBuilder

Builds the HttpRequest.

build() - 类中的方法 io.github.wooenrico.http.URLConnection.NativeHttpClientBuilder

Builds a new NativeHttpClient.

build() - 类中的方法 io.github.wooenrico.http.URLConnection.ProxyBasicAuthNativeHttpClientBuilder

C

close() - 类中的方法 io.github.wooenrico.kafka.consumer.AbstractExecutorKafkaConsumer

close() - 类中的方法 io.github.wooenrico.kafka.consumer.AbstractExecutorKafkaReceiver

close() - 类中的方法 io.github.wooenrico.kafka.consumer.AbstractKafkaConsumer

close() - 类中的方法 io.github.wooenrico.kafka.consumer.AbstractKafkaReceiver

close() - 类中的方法 io.github.wooenrico.kafka.sender.KafkaProducer

close() - 类中的方法 io.github.wooenrico.kafka.sender.ReactorKafkaSender

COMMIT_ID - 类中的静态变量 io.github.wooenrico.ProjectVersion

git commit id.

CONNECT - enum class 中的枚举常量 io.github.wooenrico.http.common.Method

CONNECT

connectTimeout - 类中的变量 io.github.wooenrico.http.URLConnection.NativeHttpClientBuilder

connectTimeout in milliseconds

consumerProperties - 类中的变量 io.github.wooenrico.kafka.consumer.AbstractKafkaConsumer

consumerProperties - 类中的变量 io.github.wooenrico.kafka.consumer.AbstractKafkaReceiver

ConsumerProperties - io.github.wooenrico.kafka.consumer中的类

消费者配置

ConsumerProperties() - 类的构造器 io.github.wooenrico.kafka.consumer.ConsumerProperties

D

DefaultKafkaConsumer - io.github.wooenrico.kafka.consumer中的类

DefaultKafkaConsumer(String, RateLimitExecutorConsumerProperties, Consumer<ConsumerRecord<String, String>>) - 类的构造器 io.github.wooenrico.kafka.consumer.DefaultKafkaConsumer

DefaultKafkaConsumer(String, RateLimitExecutorConsumerProperties, Consumer<ConsumerRecord<String, String>>, ConsumerRebalanceListener) - 类的构造器 io.github.wooenrico.kafka.consumer.DefaultKafkaConsumer

DefaultKafkaHandler - io.github.wooenrico.kafka.handler中的接口

Default Kafka Handler.

DefaultKafkaProducer - io.github.wooenrico.kafka.sender中的类

DefaultKafkaProducer(Properties) - 类的构造器 io.github.wooenrico.kafka.sender.DefaultKafkaProducer

DefaultKafkaReceiver - io.github.wooenrico.kafka.consumer中的类

DefaultKafkaReceiver(String, RateLimitExecutorConsumerProperties, Function<ConsumerRecord<String, String>, Mono<Void>>) - 类的构造器 io.github.wooenrico.kafka.consumer.DefaultKafkaReceiver

DefaultKafkaReceiver(String, RateLimitExecutorConsumerProperties, Function<ConsumerRecord<String, String>, Mono<Void>>, Consumer<Collection<ReceiverPartition>>, Consumer<Collection<ReceiverPartition>>) - 类的构造器 io.github.wooenrico.kafka.consumer.DefaultKafkaReceiver

DefaultReactorKafkaHandler - io.github.wooenrico.kafka.handler中的接口

Default Reactor Kafka Handler.

DefaultReactorKafkaSender - io.github.wooenrico.kafka.sender中的类

DefaultReactorKafkaSender(SenderProperties) - 类的构造器 io.github.wooenrico.kafka.sender.DefaultReactorKafkaSender

DefaultReactorKafkaSender(SenderProperties, Consumer<SenderResult<ProducerRecord<String, String>>>) - 类的构造器 io.github.wooenrico.kafka.sender.DefaultReactorKafkaSender

DELETE - enum class 中的枚举常量 io.github.wooenrico.http.common.Method

DELETE

destroy() - 类中的方法 io.github.wooenrico.kafka.consumer.KafkaConsumerFactory

E

execute(HttpRequest) - 接口中的方法 io.github.wooenrico.http.common.HttpExecutor

执行http请求

execute(HttpRequest) - 类中的方法 io.github.wooenrico.http.URLConnection.NativeHttpClient

execute(HttpRequest, Executor) - 接口中的方法 io.github.wooenrico.http.common.HttpExecutor

异步执行http请求

execute(HttpRequest, Executor) - 类中的方法 io.github.wooenrico.http.URLConnection.NativeHttpClient

ExecutorConf - io.github.wooenrico.kafka中的类

ExecutorConf() - 类的构造器 io.github.wooenrico.kafka.ExecutorConf

ExecutorConsumerProperties - io.github.wooenrico.kafka.consumer中的类

线程池消费者配置

ExecutorConsumerProperties() - 类的构造器 io.github.wooenrico.kafka.consumer.ExecutorConsumerProperties

executorHandle(ConsumerRecord<K, V>) - 类中的方法 io.github.wooenrico.kafka.consumer.AbstractExecutorKafkaConsumer

executorHandle(ConsumerRecord<K, V>) - 类中的方法 io.github.wooenrico.kafka.consumer.AbstractExecutorKafkaReceiver

executorHandle(ConsumerRecord<K, V>) - 类中的方法 io.github.wooenrico.kafka.consumer.AbstractRateLimitExecutorKafkaConsumer

executorHandle(ConsumerRecord<K, V>) - 类中的方法 io.github.wooenrico.kafka.consumer.AbstractRateLimitExecutorKafkaReceiver

G

GET - enum class 中的枚举常量 io.github.wooenrico.http.common.Method

GET

getBasicAuthorization() - 类中的方法 io.github.wooenrico.http.common.HttpProxy

proxy auth header

getBody() - 类中的方法 io.github.wooenrico.http.common.HttpRequest

Returns the body of the request.

getBody() - 类中的方法 io.github.wooenrico.http.common.HttpResponse

Returns the body of the response.

getCloseTimeout() - 类中的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

getCloseTimeout() - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

getCommonConsumerProperties() - 类中的方法 io.github.wooenrico.kafka.KafkaProperties

getCommonSenderProperties() - 类中的方法 io.github.wooenrico.kafka.KafkaProperties

getConcurrency() - 类中的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

getConnectTimeout() - 类中的方法 io.github.wooenrico.http.URLConnection.NativeHttpClient

Returns the connectTimeout of the client.

getConsumer() - 类中的方法 io.github.wooenrico.kafka.KafkaProperties

getConsumerProperties(String) - 类中的方法 io.github.wooenrico.kafka.KafkaProperties

getConsumerSet() - 类中的方法 io.github.wooenrico.kafka.KafkaProperties

getCorePoolSize() - 类中的方法 io.github.wooenrico.kafka.ExecutorConf

getDesc() - 类中的方法 io.github.wooenrico.http.common.HttpResponse

Returns the desc of the response.

getEnabled() - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

getExecutor() - 类中的方法 io.github.wooenrico.kafka.consumer.ExecutorConsumerProperties

getHandlerBeanName() - 类中的方法 io.github.wooenrico.kafka.BeanNameRateLimitExecutorConsumerProperties

getHeaders() - 类中的方法 io.github.wooenrico.http.common.HttpRequest

Returns the headers of the request.

getHeaders() - 类中的方法 io.github.wooenrico.http.common.HttpResponse

Returns the headers of the response.

getHostnameVerifier() - 类中的方法 io.github.wooenrico.http.URLConnection.NativeHttpClient

Returns the HostnameVerifier of the client.

getInet4HostName() - 类中的静态方法 io.github.wooenrico.NetUtils

获取主机名

getInet6HostName() - 类中的静态方法 io.github.wooenrico.NetUtils

获取主机名

getKafkaConsumerFactory(KafkaProperties) - 类中的方法 io.github.wooenrico.kafka.configuration.AutoKafkaConfiguration

getKeepAliveTimeMill() - 类中的方法 io.github.wooenrico.kafka.ExecutorConf

getLocalInet4Address() - 类中的静态方法 io.github.wooenrico.NetUtils

获取ipv4 网络地址

getLocalInet6Address() - 类中的静态方法 io.github.wooenrico.NetUtils

获取ipv6 网络地址

getLocalInetAddress() - 类中的静态方法 io.github.wooenrico.NetUtils

获取本地网络地址

getLocalInetAddress(Class<T>) - 类中的静态方法 io.github.wooenrico.NetUtils

根据网络类型获取网络地址

getMaximumPoolSize() - 类中的方法 io.github.wooenrico.kafka.ExecutorConf

getMethod() - 类中的方法 io.github.wooenrico.http.common.HttpRequest

Returns the HTTP method of the request.

getPollTimeout() - 类中的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

getProperties() - 类中的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

getProperties() - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

getProxy() - 类中的方法 io.github.wooenrico.http.URLConnection.NativeHttpClient

Returns the Proxy of the client.

getQueueSize() - 类中的方法 io.github.wooenrico.kafka.ExecutorConf

getQueueSize() - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

getRate() - 类中的方法 io.github.wooenrico.kafka.consumer.RateLimitExecutorConsumerProperties

getReadTimeout() - 类中的方法 io.github.wooenrico.http.URLConnection.NativeHttpClient

Returns the readTimeout of the client.

getSender() - 类中的方法 io.github.wooenrico.kafka.KafkaProperties

getSenderProperties(String) - 类中的方法 io.github.wooenrico.kafka.KafkaProperties

getSenderSet() - 类中的方法 io.github.wooenrico.kafka.KafkaProperties

getSinksCacheSize() - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

getSinksEmitTimeout() - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

getSinksSubscribeAwait() - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

getSslContext() - 类中的方法 io.github.wooenrico.http.URLConnection.NativeHttpClient

Returns the SSLContext of the client.

getStatus() - 类中的方法 io.github.wooenrico.http.common.HttpResponse

Returns the status of the response.

getThreadGroup() - 类中的方法 io.github.wooenrico.kafka.NamedThreadFactory

getThreadName() - 类中的方法 io.github.wooenrico.kafka.NamedThreadFactory

getThreadPriority() - 类中的方法 io.github.wooenrico.kafka.NamedThreadFactory

getTopic() - 类中的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

getUrl() - 类中的方法 io.github.wooenrico.http.common.HttpRequest

Returns the URL of the request.

getUrlConnection(URL) - 类中的方法 io.github.wooenrico.http.URLConnection.NativeHttpClient

Returns the HttpURLConnection of the URL.

getUrlConnection(URL) - 类中的方法 io.github.wooenrico.http.URLConnection.ProxyBasicAuthNativeHttpClient

getVersion() - 类中的方法 io.github.wooenrico.http.common.HttpResponse

Returns the version of the response.

H

handle(ConsumerRecords<K, V>) - 类中的方法 io.github.wooenrico.kafka.consumer.AbstractExecutorKafkaConsumer

handle(ConsumerRecords<K, V>) - 类中的方法 io.github.wooenrico.kafka.consumer.AbstractKafkaConsumer

handle(Flux<ConsumerRecord<K, V>>) - 类中的方法 io.github.wooenrico.kafka.consumer.AbstractExecutorKafkaReceiver

handle(Flux<ConsumerRecord<K, V>>) - 类中的方法 io.github.wooenrico.kafka.consumer.AbstractKafkaReceiver

HEAD - enum class 中的枚举常量 io.github.wooenrico.http.common.Method

HEAD

header(String, String) - 类中的方法 io.github.wooenrico.http.common.HttpRequestBuilder

Adds a header to the HttpRequest.

headers(Map<String, String>) - 类中的方法 io.github.wooenrico.http.common.HttpRequestBuilder

Sets the headers for the HttpRequest.

hostnameVerifier - 类中的变量 io.github.wooenrico.http.URLConnection.NativeHttpClientBuilder

HostnameVerifier

HttpExecutor - io.github.wooenrico.http.common中的接口

HttpExecutor

HttpProxy - io.github.wooenrico.http.common中的类

HttpProxy Object

HttpProxy(Proxy.Type, SocketAddress) - 类的构造器 io.github.wooenrico.http.common.HttpProxy

Creates an entry representing a PROXY connection.

HttpProxy(Proxy.Type, SocketAddress, String, String) - 类的构造器 io.github.wooenrico.http.common.HttpProxy

Creates an entry representing a PROXY connection.

HttpRequest - io.github.wooenrico.http.common中的类

HttpRequest Object

HttpRequest(String, Method, Map<String, String>, byte[]) - 类的构造器 io.github.wooenrico.http.common.HttpRequest

Constructs a new HttpRequest.

HttpRequestBuilder - io.github.wooenrico.http.common中的类

Builder for HttpRequest objects.

HttpRequestBuilder() - 类的构造器 io.github.wooenrico.http.common.HttpRequestBuilder

HttpResponse - io.github.wooenrico.http.common中的类

HttpResponse Object

HttpResponse(int, String, String, Map<String, List<String>>, byte[]) - 类的构造器 io.github.wooenrico.http.common.HttpResponse

Constructs a new HttpResponse.

I

IKafkaHandler - io.github.wooenrico.kafka.handler中的接口

Kafka Handler.

InputStreamUtil - io.github.wooenrico中的类

InputStream Util.

InputStreamUtil() - 类的构造器 io.github.wooenrico.InputStreamUtil

io.github.wooenrico - 程序包 io.github.wooenrico

io.github.wooenrico.http.common - 程序包 io.github.wooenrico.http.common

io.github.wooenrico.http.URLConnection - 程序包 io.github.wooenrico.http.URLConnection

io.github.wooenrico.kafka - 程序包 io.github.wooenrico.kafka

io.github.wooenrico.kafka.annotation - 程序包 io.github.wooenrico.kafka.annotation

io.github.wooenrico.kafka.configuration - 程序包 io.github.wooenrico.kafka.configuration

io.github.wooenrico.kafka.consumer - 程序包 io.github.wooenrico.kafka.consumer

io.github.wooenrico.kafka.handler - 程序包 io.github.wooenrico.kafka.handler

io.github.wooenrico.kafka.sender - 程序包 io.github.wooenrico.kafka.sender

isDaemon() - 类中的方法 io.github.wooenrico.kafka.NamedThreadFactory

isEnabled() - 类中的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

K

KafkaConsumerFactory - io.github.wooenrico.kafka.consumer中的类

KafkaConsumerFactory(KafkaProperties) - 类的构造器 io.github.wooenrico.kafka.consumer.KafkaConsumerFactory

KafkaHandler<K,V> - io.github.wooenrico.kafka.handler中的接口

Kafka Handler.

KafkaProducer<K,V> - io.github.wooenrico.kafka.sender中的类

KafkaProducer(Properties, Serializer<K>, Serializer<V>) - 类的构造器 io.github.wooenrico.kafka.sender.KafkaProducer

kafkaProperties() - 类中的方法 io.github.wooenrico.kafka.configuration.AutoKafkaConfiguration

KafkaProperties - io.github.wooenrico.kafka中的类

KafkaProperties() - 类的构造器 io.github.wooenrico.kafka.KafkaProperties

KafkaUtil - io.github.wooenrico.kafka中的类

KafkaUtil() - 类的构造器 io.github.wooenrico.kafka.KafkaUtil

keepAlive(boolean) - 类中的方法 io.github.wooenrico.http.common.HttpRequestBuilder

Sets the header for the HttpRequest.

keyDeserializer - 类中的变量 io.github.wooenrico.kafka.consumer.AbstractKafkaConsumer

keyDeserializer - 类中的变量 io.github.wooenrico.kafka.consumer.AbstractKafkaReceiver

keySerializer - 类中的变量 io.github.wooenrico.kafka.sender.KafkaProducer

keySerializer - 类中的变量 io.github.wooenrico.kafka.sender.ReactorKafkaSender

M

mergeProperties(Properties, Properties) - 类中的静态方法 io.github.wooenrico.kafka.KafkaUtil

method(Method) - 类中的方法 io.github.wooenrico.http.common.HttpRequestBuilder

Sets the HTTP method for the HttpRequest.

Method - io.github.wooenrico.http.common中的Enum Class

Http Method

N

name - 类中的变量 io.github.wooenrico.kafka.consumer.AbstractKafkaConsumer

name - 类中的变量 io.github.wooenrico.kafka.consumer.AbstractKafkaReceiver

NamedThreadFactory - io.github.wooenrico.kafka中的类

NamedThreadFactory(String) - 类的构造器 io.github.wooenrico.kafka.NamedThreadFactory

NamedThreadFactory(String, boolean) - 类的构造器 io.github.wooenrico.kafka.NamedThreadFactory

NamedThreadFactory(String, boolean, int) - 类的构造器 io.github.wooenrico.kafka.NamedThreadFactory

NativeHttpClient - io.github.wooenrico.http.URLConnection中的类

NativeHttpClient

NativeHttpClient(SSLContext, HostnameVerifier, Proxy, int, int) - 类的构造器 io.github.wooenrico.http.URLConnection.NativeHttpClient

Constructs a new NativeHttpClient.

NativeHttpClientBuilder - io.github.wooenrico.http.URLConnection中的类

Builder for NativeHttpClient objects.

NativeHttpClientBuilder() - 类的构造器 io.github.wooenrico.http.URLConnection.NativeHttpClientBuilder

NetUtils - io.github.wooenrico中的类

网络工具类

NetUtils() - 类的构造器 io.github.wooenrico.NetUtils

newSingleThreadPoolExecutor(String) - 类中的静态方法 io.github.wooenrico.kafka.KafkaUtil

newThread(Runnable) - 类中的方法 io.github.wooenrico.kafka.NamedThreadFactory

newThreadPoolExecutor(ExecutorConf, ThreadFactory) - 类中的静态方法 io.github.wooenrico.kafka.KafkaUtil

newThreadPoolExecutor(String, ExecutorConsumerProperties) - 类中的静态方法 io.github.wooenrico.kafka.KafkaUtil

nextThreadName() - 类中的方法 io.github.wooenrico.kafka.NamedThreadFactory

O

onAssign - 类中的变量 io.github.wooenrico.kafka.consumer.AbstractKafkaReceiver

onRevoke - 类中的变量 io.github.wooenrico.kafka.consumer.AbstractKafkaReceiver

OPTIONS - enum class 中的枚举常量 io.github.wooenrico.http.common.Method

OPTIONS

P

PATCH - enum class 中的枚举常量 io.github.wooenrico.http.common.Method

PATCH

POST - enum class 中的枚举常量 io.github.wooenrico.http.common.Method

POST

prettyString() - 类中的方法 io.github.wooenrico.http.common.HttpRequest

Returns a pretty string representation of the HTTP request.

prettyString() - 类中的方法 io.github.wooenrico.http.common.HttpResponse

Returns the response as a pretty string.

ProducerRecordReactorKafkaSender<K,V> - io.github.wooenrico.kafka.sender中的类

ProducerRecordReactorKafkaSender(SenderProperties, Serializer<K>, Serializer<V>) - 类的构造器 io.github.wooenrico.kafka.sender.ProducerRecordReactorKafkaSender

ProducerRecordReactorKafkaSender(SenderProperties, Serializer<K>, Serializer<V>, Consumer<SenderResult<ProducerRecord<K, V>>>) - 类的构造器 io.github.wooenrico.kafka.sender.ProducerRecordReactorKafkaSender

ProjectVersion - io.github.wooenrico中的类

Project version information.

ProjectVersion() - 类的构造器 io.github.wooenrico.ProjectVersion

properties - 类中的变量 io.github.wooenrico.kafka.sender.KafkaProducer

properties - 类中的变量 io.github.wooenrico.kafka.sender.ReactorKafkaSender

proxy - 类中的变量 io.github.wooenrico.http.URLConnection.NativeHttpClientBuilder

Proxy

Proxy_Authorization_Header_Name - 类中的静态变量 io.github.wooenrico.http.common.HttpProxy

Proxy-Authorization header name

ProxyBasicAuthNativeHttpClient - io.github.wooenrico.http.URLConnection中的类

NativeHttpClient with Proxy Basic Auth

ProxyBasicAuthNativeHttpClient(SSLContext, HostnameVerifier, Proxy, int, int) - 类的构造器 io.github.wooenrico.http.URLConnection.ProxyBasicAuthNativeHttpClient

Constructs a new ProxyBasicAuthNativeHttpClient.

ProxyBasicAuthNativeHttpClientBuilder - io.github.wooenrico.http.URLConnection中的类

Builder for ProxyBasicAuthNativeHttpClient objects.

ProxyBasicAuthNativeHttpClientBuilder() - 类的构造器 io.github.wooenrico.http.URLConnection.ProxyBasicAuthNativeHttpClientBuilder

PUT - enum class 中的枚举常量 io.github.wooenrico.http.common.Method

PUT

R

RateLimitExecutorConsumerProperties - io.github.wooenrico.kafka.consumer中的类

速率限制线程池消费者配置

RateLimitExecutorConsumerProperties() - 类的构造器 io.github.wooenrico.kafka.consumer.RateLimitExecutorConsumerProperties

rateLimitHandle(ConsumerRecord<String, String>) - 类中的方法 io.github.wooenrico.kafka.consumer.DefaultKafkaConsumer

rateLimitHandle(ConsumerRecord<String, String>) - 类中的方法 io.github.wooenrico.kafka.consumer.DefaultKafkaReceiver

rateLimitHandle(ConsumerRecord<K, V>) - 类中的方法 io.github.wooenrico.kafka.consumer.AbstractRateLimitExecutorKafkaConsumer

rateLimitHandle(ConsumerRecord<K, V>) - 类中的方法 io.github.wooenrico.kafka.consumer.AbstractRateLimitExecutorKafkaReceiver

ReactorKafkaHandler<K,V> - io.github.wooenrico.kafka.handler中的接口

Reactor Kafka Handler.

reactorKafkaSender(KafkaProperties) - 类中的方法 io.github.wooenrico.kafka.configuration.AutoKafkaConfiguration

ReactorKafkaSender<K,V,T> - io.github.wooenrico.kafka.sender中的类

ReactorKafkaSender(SenderProperties, Serializer<K>, Serializer<V>) - 类的构造器 io.github.wooenrico.kafka.sender.ReactorKafkaSender

ReactorKafkaSender(SenderProperties, Serializer<K>, Serializer<V>, Consumer<SenderResult<T>>) - 类的构造器 io.github.wooenrico.kafka.sender.ReactorKafkaSender

readAndClose(InputStream) - 类中的静态方法 io.github.wooenrico.InputStreamUtil

Read the inputStream and close it.

readTimeout - 类中的变量 io.github.wooenrico.http.URLConnection.NativeHttpClientBuilder

readTimeout in milliseconds

S

SCM_BRANCH - 类中的静态变量 io.github.wooenrico.ProjectVersion

git branch name.

send(String, Integer, Long, K, V) - 类中的方法 io.github.wooenrico.kafka.sender.KafkaProducer

send(String, Integer, Long, K, V) - 类中的方法 io.github.wooenrico.kafka.sender.ProducerRecordReactorKafkaSender

send(String, Integer, Long, K, V, Callback) - 类中的方法 io.github.wooenrico.kafka.sender.KafkaProducer

send(String, Integer, K, V) - 类中的方法 io.github.wooenrico.kafka.sender.KafkaProducer

send(String, Integer, K, V) - 类中的方法 io.github.wooenrico.kafka.sender.ProducerRecordReactorKafkaSender

send(String, Integer, K, V, Callback) - 类中的方法 io.github.wooenrico.kafka.sender.KafkaProducer

send(String, K, V) - 类中的方法 io.github.wooenrico.kafka.sender.KafkaProducer

send(String, K, V) - 类中的方法 io.github.wooenrico.kafka.sender.ProducerRecordReactorKafkaSender

send(String, K, V, Callback) - 类中的方法 io.github.wooenrico.kafka.sender.KafkaProducer

send(String, V) - 类中的方法 io.github.wooenrico.kafka.sender.KafkaProducer

send(String, V) - 类中的方法 io.github.wooenrico.kafka.sender.ProducerRecordReactorKafkaSender

send(String, V, Callback) - 类中的方法 io.github.wooenrico.kafka.sender.KafkaProducer

send(ProducerRecord<K, V>) - 类中的方法 io.github.wooenrico.kafka.sender.KafkaProducer

send(ProducerRecord<K, V>, Callback) - 类中的方法 io.github.wooenrico.kafka.sender.KafkaProducer

send(ProducerRecord<K, V>, T) - 类中的方法 io.github.wooenrico.kafka.sender.ReactorKafkaSender

提交队列失败，直接写入

send(Publisher<SenderRecord<K, V, T>>) - 类中的方法 io.github.wooenrico.kafka.sender.ReactorKafkaSender

kafka 直接写入

send(SenderRecord<K, V, T>) - 类中的方法 io.github.wooenrico.kafka.sender.ReactorKafkaSender

kafka 直接写入

SenderProperties - io.github.wooenrico.kafka.sender中的类

SenderProperties() - 类的构造器 io.github.wooenrico.kafka.sender.SenderProperties

setApplicationContext(ApplicationContext) - 类中的方法 io.github.wooenrico.kafka.consumer.KafkaConsumerFactory

setCloseTimeout(Duration) - 类中的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

setCloseTimeout(Duration) - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

setCommonConsumerProperties(Properties) - 类中的方法 io.github.wooenrico.kafka.KafkaProperties

setCommonSenderProperties(Properties) - 类中的方法 io.github.wooenrico.kafka.KafkaProperties

setConcurrency(int) - 类中的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

setConnectTimeout(int) - 类中的方法 io.github.wooenrico.http.URLConnection.NativeHttpClientBuilder

Sets the connectTimeout for the NativeHttpClient.

setConsumer(Map<String, BeanNameRateLimitExecutorConsumerProperties>) - 类中的方法 io.github.wooenrico.kafka.KafkaProperties

setCorePoolSize(int) - 类中的方法 io.github.wooenrico.kafka.ExecutorConf

setEnabled(boolean) - 类中的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

setEnabled(Boolean) - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

setExecutor(ExecutorConf) - 类中的方法 io.github.wooenrico.kafka.consumer.ExecutorConsumerProperties

setHandlerBeanName(String) - 类中的方法 io.github.wooenrico.kafka.BeanNameRateLimitExecutorConsumerProperties

setHostnameVerifier(HostnameVerifier) - 类中的方法 io.github.wooenrico.http.URLConnection.NativeHttpClientBuilder

Sets the HostnameVerifier for the NativeHttpClient.

setKeepAliveTimeMill(long) - 类中的方法 io.github.wooenrico.kafka.ExecutorConf

setMaximumPoolSize(int) - 类中的方法 io.github.wooenrico.kafka.ExecutorConf

setPollTimeout(Duration) - 类中的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

setProperties(Properties) - 类中的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

setProperties(Properties) - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

setProxy(Proxy) - 类中的方法 io.github.wooenrico.http.URLConnection.NativeHttpClientBuilder

Sets the Proxy for the NativeHttpClient.

setQueueSize(int) - 类中的方法 io.github.wooenrico.kafka.ExecutorConf

setQueueSize(int) - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

setRate(Double) - 类中的方法 io.github.wooenrico.kafka.consumer.RateLimitExecutorConsumerProperties

setReadTimeout(int) - 类中的方法 io.github.wooenrico.http.URLConnection.NativeHttpClientBuilder

Sets the readTimeout for the NativeHttpClient.

setSender(Map<String, SenderProperties>) - 类中的方法 io.github.wooenrico.kafka.KafkaProperties

setSinksCacheSize(long) - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

setSinksEmitTimeout(Duration) - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

setSinksSubscribeAwait(Duration) - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

setSslContext(SSLContext) - 类中的方法 io.github.wooenrico.http.URLConnection.NativeHttpClientBuilder

Sets the SSLContext for the NativeHttpClient.

setTopic(List<String>) - 类中的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

sslContext - 类中的变量 io.github.wooenrico.http.URLConnection.NativeHttpClientBuilder

SSLContext

T

TIMESTAMP - 类中的静态变量 io.github.wooenrico.ProjectVersion

build timestamp.

toString() - 类中的方法 io.github.wooenrico.http.common.HttpRequest

Returns a string representation of the HTTP request.

toString() - 类中的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

toString() - 类中的方法 io.github.wooenrico.kafka.ExecutorConf

toString() - 类中的方法 io.github.wooenrico.kafka.sender.SenderProperties

TRACE - enum class 中的枚举常量 io.github.wooenrico.http.common.Method

TRACE

U

url(String) - 类中的方法 io.github.wooenrico.http.common.HttpRequestBuilder

Sets the URL for the HttpRequest.

urlParam(String, String) - 类中的方法 io.github.wooenrico.http.common.HttpRequestBuilder

Sets the URL parameter for the HttpRequest.

V

valueDeserializer - 类中的变量 io.github.wooenrico.kafka.consumer.AbstractKafkaConsumer

valueDeserializer - 类中的变量 io.github.wooenrico.kafka.consumer.AbstractKafkaReceiver

valueOf(String) - enum class中的静态方法 io.github.wooenrico.http.common.Method

Returns the enum constant of this class with the specified name.

values() - enum class中的静态方法 io.github.wooenrico.http.common.Method

Returns an array containing the constants of this enum class, in the order they are declared.

valueSerializer - 类中的变量 io.github.wooenrico.kafka.sender.KafkaProducer

valueSerializer - 类中的变量 io.github.wooenrico.kafka.sender.ReactorKafkaSender

VERSION - 类中的静态变量 io.github.wooenrico.ProjectVersion

version information.

A B C D E G H I K M N O P R S T U V
All Classes and Interfaces|常量字段值|所有程序包|序列化表格