程序包 run.mone.trace.etl.extension.kafka

类 KafkaExtension

java.lang.Object

run.mone.trace.etl.extension.kafka.KafkaExtension

所有已实现的接口:

MQExtension<org.apache.kafka.clients.producer.ProducerRecord<String,String>,org.apache.kafka.clients.consumer.ConsumerRecords<String,String>>

@Service
@ConditionalOnProperty(name="mq.type",
                       havingValue="kafka")
public class KafkaExtension
extends Object
implements MQExtension<org.apache.kafka.clients.producer.ProducerRecord<String,String>,org.apache.kafka.clients.consumer.ConsumerRecords<String,String>>

构造器概要

构造器

构造器	说明
KafkaExtension()

方法概要

修饰符和类型	方法	说明
void	initMq(MqConfig<org.apache.kafka.clients.consumer.ConsumerRecords<String,String>> config)
void	send(List<org.apache.kafka.clients.producer.ProducerRecord<String,String>> messages)
void	send(org.apache.kafka.clients.producer.ProducerRecord<String,String> message)
void	sendByTraceId(String traceId, org.apache.kafka.clients.producer.ProducerRecord<String,String> message)

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

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

构造器详细资料

KafkaExtension

public KafkaExtension()

方法详细资料

initMq

public void initMq(MqConfig<org.apache.kafka.clients.consumer.ConsumerRecords<String,String>> config)

指定者:

initMq 在接口中 MQExtension<org.apache.kafka.clients.producer.ProducerRecord<String,String>,org.apache.kafka.clients.consumer.ConsumerRecords<String,String>>

send

public void send(org.apache.kafka.clients.producer.ProducerRecord<String,String> message)

指定者:

send 在接口中 MQExtension<org.apache.kafka.clients.producer.ProducerRecord<String,String>,org.apache.kafka.clients.consumer.ConsumerRecords<String,String>>

send

public void send(List<org.apache.kafka.clients.producer.ProducerRecord<String,String>> messages)

指定者:

send 在接口中 MQExtension<org.apache.kafka.clients.producer.ProducerRecord<String,String>,org.apache.kafka.clients.consumer.ConsumerRecords<String,String>>

sendByTraceId

public void sendByTraceId(String traceId,
 org.apache.kafka.clients.producer.ProducerRecord<String,String> message)

指定者:

sendByTraceId 在接口中 MQExtension<org.apache.kafka.clients.producer.ProducerRecord<String,String>,org.apache.kafka.clients.consumer.ConsumerRecords<String,String>>