Activities of "liangshiwei"

Hi,

It looks like no problem, Can you share a project with me or full steps to reproduce? shiwei.liang@volosoft.com I will check it out.

Hi,

I created an internal issue to discuss, I will let you know if there is any news.

Hi,

Can you share the ProductController class code?

Hi,

Can you explain it in detail? thanks.

Hi,

Can you share a project that can reproduce the problem with me? shiwei.liang@volosoft.com I will check it out. thanks.

Hi,

I'm sorry to say for the current design, it's not possible, Kafka is different from RabbitMQ, it does not have Exchange and routeing keys.

But Kafka consumers can subscribe to multiple topics, you can try this:

[ExposeServices(typeof(KafkaMessageConsumer), typeof(IKafkaMessageConsumer))]
public class MyKafkaMessageConsumer : KafkaMessageConsumer
{
    private static readonly PropertyInfo ConsumerProperty;

    static MyKafkaMessageConsumer()
    {
        var type = typeof(KafkaMessageConsumer);
        ConsumerProperty = type.GetProperty("Consumer", BindingFlags.Instance | BindingFlags.NonPublic);
    }

    public MyKafkaMessageConsumer(IConsumerPool consumerPool, IExceptionNotifier exceptionNotifier,
        IOptions<AbpKafkaOptions> options, IProducerPool producerPool, AbpAsyncTimer timer) : base(consumerPool,
        exceptionNotifier, options, producerPool, timer)
    {
    }

    protected override void Consume()
    {
        ConsumerProperty.SetValue(this, ConsumerPool.Get(GroupId, ConnectionName));

        Task.Factory.StartNew(async () =>
        {
            Consumer.Subscribe(new []{ "MyTopicName", "MyTopicName2",.....});

            while (true)
            {
                try
                {
                    var consumeResult = Consumer.Consume();

                    if (consumeResult.IsPartitionEOF)
                    {
                        continue;
                    }

                    await HandleIncomingMessage(consumeResult);
                }
                catch (ConsumeException ex)
                {
                    Logger.LogException(ex, LogLevel.Warning);
                    await ExceptionNotifier.NotifyAsync(ex, logLevel: LogLevel.Warning);
                }
            }
        }, TaskCreationOptions.LongRunning);
    }
}

Hi,

Can you explain it in detail? thanks.

For now, you can try this:

Add to your *.ApplicationAutoMapperProfile

CreateMap<ApiResourceSecret, ApiResourceSecretDto>()
    .ForMember(d => d.Value, x => x.MapFrom(_ => _.Value));

CreateMap<ClientSecret, ClientSecretDto>()
    .ForMember(d => d.Value, x => x.MapFrom(_ => _.Value));

Hi,

The IdentityServerCacheItemInvalidator is a local event handler class, so I think RabbitMQ will not affect it.

To reproduce, you can create a new client in Administration > Identity Server > Clients, add a Secret. Save the client and then add another Secret and delete the previous. When you try to save, it will show the error.

I could reproduce the problem, we will fix it in the patch version, your ticket has been refunded.

We will fix it in the patch version, your ticket has been refunded.

See: https://github.com/abpframework/abp/issues/13285