using Confluent.Kafka;
using System;
using System.Collections.Generic;
using System.Text;
using VOL.Core.Configuration;
namespace VOL.Core.KafkaManager
{
///
/// 配置类
///
public class KafkaConfig
{
///
/// 构造配置类
///
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,
};
}
///
/// 消费者配置文件
///
public ConsumerConfig ConsumerConfig;
///
/// 生产者配置文件
///
public ProducerConfig ProducerConfig;
}
}