org.zodiac.actuate.kafka

类 KafkaEndpoint

java.lang.Object

org.zodiac.actuate.kafka.KafkaEndpoint

@Endpoint(id="kafka")
public class KafkaEndpoint
extends Object

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	KafkaEndpoint.OperationAction
static class	KafkaEndpoint.OperationMode
static class	KafkaEndpoint.OperationResponse

字段概要

字段

限定符和类型	字段和说明
private org.springframework.kafka.config.KafkaListenerEndpointRegistry	kafkaListenerEndpointRegistry
protected org.slf4j.Logger	logger

构造器概要

构造器

构造器和说明
KafkaEndpoint(org.springframework.kafka.config.KafkaListenerEndpointRegistry kafkaListenerEndpointRegistry)

方法概要

限定符和类型	方法和说明
private void	disableKafkaTopicIfNecessary(org.springframework.kafka.listener.MessageListenerContainer messageListenerContainer, KafkaEndpoint.OperationMode opMode, String... topics)
private void	enableKafkaTopicIfNecessary(org.springframework.kafka.listener.MessageListenerContainer messageListenerContainer, KafkaEndpoint.OperationMode opMode, String... topics)
KafkaEndpoint.OperationResponse	execOperationOnKafkaTopics(int mode, int action, String topics) Execute operations on kafka topics.
private boolean	isMatch(KafkaEndpoint.OperationMode opMode, org.springframework.kafka.listener.ContainerProperties containerProperties, String... topics)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

logger

protected org.slf4j.Logger logger

kafkaListenerEndpointRegistry

private org.springframework.kafka.config.KafkaListenerEndpointRegistry kafkaListenerEndpointRegistry

构造器详细资料

KafkaEndpoint

public KafkaEndpoint(org.springframework.kafka.config.KafkaListenerEndpointRegistry kafkaListenerEndpointRegistry)

方法详细资料

execOperationOnKafkaTopics

@WriteOperation
public KafkaEndpoint.OperationResponse execOperationOnKafkaTopics(@Selector
                                                                                   int mode,
                                                                                   @Selector
                                                                                   int action,
                                                                                   @Selector
                                                                                   String topics)

Execute operations on kafka topics.

参数:

mode - target operation mode, @see KafkaEndpoint.OperationMode .

action - target action, @see KafkaEndpoint.OperationAction.

topics - target operations.

返回:

operation result

enableKafkaTopicIfNecessary

private void enableKafkaTopicIfNecessary(org.springframework.kafka.listener.MessageListenerContainer messageListenerContainer,
                                         KafkaEndpoint.OperationMode opMode,
                                         String... topics)

disableKafkaTopicIfNecessary

private void disableKafkaTopicIfNecessary(org.springframework.kafka.listener.MessageListenerContainer messageListenerContainer,
                                          KafkaEndpoint.OperationMode opMode,
                                          String... topics)

isMatch

private boolean isMatch(KafkaEndpoint.OperationMode opMode,
                        org.springframework.kafka.listener.ContainerProperties containerProperties,
                        String... topics)