You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
|
|
|
|
|
////using Confluent.Kafka;
|
|
|
|
|
|
//using System;
|
|
|
|
|
|
//using System.Collections.Generic;
|
|
|
|
|
|
//using System.Text;
|
|
|
|
|
|
//using VOL.Core.Configuration;
|
|
|
|
|
|
|
|
|
|
|
|
//namespace VOL.Core.KafkaManager
|
|
|
|
|
|
//{
|
|
|
|
|
|
// /// <summary>
|
|
|
|
|
|
// /// 配置类
|
|
|
|
|
|
// /// </summary>
|
|
|
|
|
|
// public class KafkaConfig
|
|
|
|
|
|
// {
|
|
|
|
|
|
// /// <summary>
|
|
|
|
|
|
// /// 构造配置类
|
|
|
|
|
|
// /// </summary>
|
|
|
|
|
|
// protected KafkaConfig()
|
|
|
|
|
|
// {
|
|
|
|
|
|
// //ProducerConfig = new ProducerConfig()
|
|
|
|
|
|
// //{
|
|
|
|
|
|
// // BootstrapServers = AppSetting.Kafka.ProducerSettings.BootstrapServers,// "192.168.20.241:9092",
|
|
|
|
|
|
// //};
|
|
|
|
|
|
|
|
|
|
|
|
// //ConsumerConfig = new ConsumerConfig()
|
|
|
|
|
|
// //{
|
|
|
|
|
|
// // BootstrapServers = AppSetting.Kafka.ConsumerSettings.BootstrapServers,
|
|
|
|
|
|
// // GroupId = AppSetting.Kafka.ConsumerSettings.GroupId,
|
|
|
|
|
|
// // AutoOffsetReset = AutoOffsetReset.Earliest,//当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，从头开始消费
|
|
|
|
|
|
// // EnableAutoCommit = false,
|
|
|
|
|
|
// // //Kafka配置安全认证
|
|
|
|
|
|
// // //SecurityProtocol = SecurityProtocol.SaslPlaintext,
|
|
|
|
|
|
// // //SaslMechanism = SaslMechanism.Plain,
|
|
|
|
|
|
// // //SaslUsername = AppSetting.Kafka.ConsumerSettings.SaslUsername,
|
|
|
|
|
|
// // //SaslPassword = AppSetting.Kafka.ConsumerSettings.SaslPassword,
|
|
|
|
|
|
// //};
|
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
|
|
// ///// <summary>
|
|
|
|
|
|
// ///// 消费者配置文件
|
|
|
|
|
|
// ///// </summary>
|
|
|
|
|
|
// //public ConsumerConfig ConsumerConfig;
|
|
|
|
|
|
|
|
|
|
|
|
// ///// <summary>
|
|
|
|
|
|
// ///// 生产者配置文件
|
|
|
|
|
|
// ///// </summary>
|
|
|
|
|
|
// //public ProducerConfig ProducerConfig;
|
|
|
|
|
|
// }
|
|
|
|
|
|
//}
|
