Compare commits
No commits in common. "0584515df9faa9668ba7c97776f286bb187cf558" and "902993e4816ecdc420583ce9351d771d2be9b881" have entirely different histories.
0584515df9
...
902993e481
@ -139,25 +139,6 @@ namespace JiShe.CollectBus.Kafka
|
|||||||
{
|
{
|
||||||
var consumerService = provider.GetRequiredService<IConsumerService>();
|
var consumerService = provider.GetRequiredService<IConsumerService>();
|
||||||
|
|
||||||
if (attr.EnableBatch)
|
|
||||||
{
|
|
||||||
await consumerService.SubscribeBatchAsync<dynamic>(attr.Topic, async (message) =>
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
// 处理消息
|
|
||||||
return await ProcessMessageAsync(message, method, subscribe);
|
|
||||||
}
|
|
||||||
catch (ConsumeException ex)
|
|
||||||
{
|
|
||||||
// 处理消费错误
|
|
||||||
logger.LogError($"kafka批量消费异常:{ex.Message}");
|
|
||||||
}
|
|
||||||
return await Task.FromResult(false);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
await consumerService.SubscribeAsync<dynamic>(attr.Topic, async (message) =>
|
await consumerService.SubscribeAsync<dynamic>(attr.Topic, async (message) =>
|
||||||
{
|
{
|
||||||
try
|
try
|
||||||
@ -174,8 +155,6 @@ namespace JiShe.CollectBus.Kafka
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 处理消息
|
/// 处理消息
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user