Kafka integration for when upgrading 5.3.0 is giving an issue #3341

4 Answer(s)

• 

  0

  liangshiwei created 3 years ago

  Support Team Fullstack Developer

  Hi,

  I will check it out.

  Save Cancel
• 

  0

  liangshiwei created 3 years ago

  Support Team Fullstack Developer

  Hi,

  We will fix the problem: https://github.com/abpframework/abp/pull/13158, your ticket has been refunded

  You can try this as a temporary solution:

  [Dependency(ReplaceServices = true)]
  [ExposeServices(typeof(IProducerPool))]
  public class MyProducerPool : ProducerPool, ISingletonDependency
  {
      public MyProducerPool(IOptions<AbpKafkaOptions> options) : base(options)
      {
      }
  
      public override IProducer<string, byte[]> Get(string connectionName = null)
      {
          connectionName ??= KafkaConnections.DefaultConnectionName;
          
          return Producers.GetOrAdd(
              connectionName, connection => new Lazy<IProducer<string, byte[]>>(() =>
              {
                  var producerConfig = new ProducerConfig(Options.Connections.GetOrDefault(connection));
                  Options.ConfigureProducer?.Invoke(producerConfig);
                  return new ProducerBuilder<string, byte[]>(producerConfig).Build();
              })).Value;
      }
  }
  

  Save Cancel
• 

  0

  tahseelit1 created 3 years ago

  Hi thank you for your quick response.,

  Save Cancel
• 

  0

  liangshiwei created 3 years ago

  Support Team Fullstack Developer

  We will release 5.3.1 version today.

  Save Cancel