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

接口 KafkaConfigure

所有已知实现类:

KafkaConfigure9092, KafkaConfigure9093, KafkaConfigure9094

public interface KafkaConfigure

方法概要

修饰符和类型	方法	说明
Properties	createConsumerProperties(MqConfig<org.apache.kafka.clients.consumer.ConsumerRecords<String,String>> config)
Properties	createProducerProperties(MqConfig<org.apache.kafka.clients.consumer.ConsumerRecords<String,String>> config)

方法详细资料

createProducerProperties

Properties createProducerProperties(MqConfig<org.apache.kafka.clients.consumer.ConsumerRecords<String,String>> config)

createConsumerProperties

Properties createConsumerProperties(MqConfig<org.apache.kafka.clients.consumer.ConsumerRecords<String,String>> config)