Activities of "paykoolbackend"

In my local test, why is the event written to the outbox table only when I set "BatchPublishOutboxEvents" to false?

I found a solution.

https://docs.abp.io/en/abp/latest/Customizing-Application-Modules-Overriding-Services#overriding-a-service-class

hi

I wrote the following code to override the DefaultAzureBlobNameCalculator service, but it cannot enter the TestBlobNameCalculator/Calculate.

And throw error "Could not found the requested BLOB 'test.pdf' in the container 'TestContainer'!".

Did I miss something?

public class TestBlobNameCalculator : DefaultAzureBlobNameCalculator
{
    public TestBlobNameCalculator(ICurrentTenant currentTenant) : base(currentTenant)
    {
    }

    public override string Calculate(BlobProviderArgs args)
    {
        if (args.ContainerName == "testContainer")
        {c
            return args.BlobName;
        }

        return base.Calculate(args);
    }
}

OK, thank you.

The strategies mentioned above are things we will do, but I would like to know if ABP has any mechanisms to handle sudden Kafka server connection failures, so that the API can operate smoothly without blocking.

Got it, thanks.

In the event of connection issues with the Kafka server, what would you recommend doing?

After our discussion, modifying the MessageTimeoutMs is not the best option for us because it's difficult to set an appropriate timeout.

We would like to handle the issue of not being able to connect to the Kafka server and do not want the API to block. Currently, we have configured the settings as follows:

Configure<AbpKafkaOptions>(options =>
{
    options.ConfigureProducer = config =>
    {
        config.EnableIdempotence = true;
        config.MessageSendMaxRetries = 3;
        config.RetryBackoffMs = 1000;
    };
});

After the retries are exhausted, we still need to wait for the MessageTimeoutMs time.(default = 300000ms) Is it possible to prioritize the retry time, so that an error is reported when the retries are exhausted?

ok, thanks

Test OK.

There is another question： Can I configure ProducerConfig and ConsumerConfig using the appsettings.json file? Or can they only be configured using the Options Classes? https://docs.abp.io/en/abp/latest/Distributed-Event-Bus-Kafka-Integration

Thanks, let me try it.