Comments (22)
如果是用着用着出问题的话,把cap.published与cap.received数据全清了。
from cap.
For any future visitors: This exception can also be triggered if you forgot to register your Queue Handlers with the Dependency Injection engine!
from cap.
在 v2.1.1+ 版本中,当应用程序启动时CAP会将默认Group设置为当前程序集名称,这样可以一定程度解决队列冲突问题。
from cap.
另外一个原因触发这个异常是:
由于不同的实例连接到了相同的数据库,CAP要求相同的实例可以连接同一个库,不同的实例需要连接不同的数据库(或使用TableNamePrefix|Schema 指定不同的表前缀|空间)。
Another reason triggers this exception:
Because different instances connect to the one database, CAP requires the same instance can connect to one database, But different instances need to connect to the different databases.
from cap.
我遇到了这个问题,有一个项目无论怎么改都会报错,但是相同的代码放在另一个项目中完美运行。
数据库里的Content字段引导我来到了这里。
from cap.
PS: if Kafka is used, there are no problems.
I'd just like to note that this does not seem to be the case, as I just received this error using Kafka. I have two copies of the same service, one with the default group and one with the group set to something different so I can guarantee one will receive all messages for testing.
from cap.
Sorry, I am not quite sure how to resolve this. Exception message brings me to this page. I tried to remove the exchange and unbind the queue. But I am still getting the exception:
{"Headers":{"cap-msg-group":"cap.queue.logserver.v1","cap-exception":"SerializationException-->Message can not be found subscriber. Name:, Group:cap.queue.logserver.v1. \r\n see: https://github.com/dotnetcore/CAP/issues/63"},"Value":"data:UnknownType;base64,ZA=="}
from cap.
@ajaffie data:UnknownType;base64,ZA==
This is because the message type you produce cannot be converted by the consumer
from cap.
from cap.
UseInMemoryMessageQueue
Message (Name:iotsharp.services.datastream.telemetrydata,Group:cap.queue.iotsharp.v1) can not be found subscriber.
from cap.
Hi, i found this error many times in my project. what i can see is that the retry processor is trying to resolve all the receive failure all the group without filtering its own subscription.
GetReceivedMessagesOfNeedRetry()
private async Task ProcessReceivedAsync(IDataStorage connection, ProcessingContext context)
{
context.ThrowIfStopping();
var messages = await GetSafelyAsync(connection.GetReceivedMessagesOfNeedRetry);
foreach (var message in messages)
{
await _subscribeDispatcher.DispatchAsync(message);
await context.WaitAsync(_delay);
}
}
do you think we should filter the events here?
from cap.
@desperazo You need to check whether you use the same event table in multiple services by mistake, different services need to have their own event tables
from cap.
查log的时候出现这个异常,最后发现真实异常可能会写在数据库cap.received,content——Headers——cap-exception中。
是SerializationException。已解决。
from cap.
我kafka也发现了一样的问题 找不到订阅者 直接卡这个找不到订阅者 不消费?
from cap.
Sorry, I am not quite sure how to resolve this. Exception message brings me to this page. I tried to remove the exchange and unbind the queue. But I am still getting the exception:
{"Headers":{"cap-msg-group":"cap.queue.logserver.v1","cap-exception":"SerializationException-->Message can not be found subscriber. Name:, Group:cap.queue.logserver.v1. \r\n see:
Is...solved?
解决了吗?
from cap.
no
from cap.
@ajaffie
data:UnknownType;base64,ZA==
This is because the message type you produce cannot be converted by the consumer
@henrydingchina yes, please see above
from cap.
我用的是kafka 但是也出现了这个报错 不知道该怎么解决
from cap.
Message (Name:SJZY.FMC.VoucherRedundantCalc,Group:cap.queue.resharpertestrunner.v1) can not be found subscriber.
see: RabbitMQ : SubscriberNotFoundException · Issue #63 · dotnetcore/CAP,我的程序名是SJZY.FMC.Api,不是resharpertestrunner
from cap.
Message (Name:SJZY.FMC.VoucherRedundantCalc,Group:cap.queue.resharpertestrunner.v1) can not be found subscriber. see: RabbitMQ : SubscriberNotFoundException · Issue #63 · dotnetcore/CAP,我的程序名是SJZY.FMC.Api,不是resharpertestrunner
你这个问题解决了吗?我现在生产者和消费者是两个不同的程序,当生产者和消费都都连接配置到同一个数据库实例时,生产者也就会收到这个错误,但是消费都是正常的。
from cap.
另外一个原因触发这个异常是:
由于不同的实例连接到了相同的数据库,CAP要求相同的实例可以连接同一个库,不同的实例需要连接不同的数据库。
请问一下:通过SqlServerStorageInitializer为不同实例各建1张数据库表,是否就可以连接到相同数据库了?
from cap.
@daimeiquan https://cap.dotnetcore.xyz/user-guide/zh/samples/faq/ Use different schema
name for different service.
from cap.
Related Issues (20)
- Add option for controlling reponse headers from OnSubscribeExecuted HOT 2
- NATS Connection Error after Restarting nats-server: Unable to Publish Messages HOT 5
- SQL Server replication readpast error! "You can only specify the READPAST lock in the READ COMMITTED or REPEATABLE READ isolation levels" HOT 3
- 一个进程内可以创建多个CAP吗? HOT 1
- NATS feature: add the possibility to disable dynamic consumer subject/topic creation through NatsCapOtpions HOT 2
- 一个程序进程会操作多个不同的业务数据库,参考#998创建多个发布者进行对应处理,消费者应该如何处理消息? HOT 1
- Feature Request: Add New Column in table Cap.published for relation to table every single data publish HOT 2
- Callback on IIS Idle state HOT 2
- Cap-dashboard empty using dynamic subscribers with Azure Service Bus HOT 1
- Feature Request:Subscribers can batch process messages HOT 1
- 现在cap支持dm8数据库吗? HOT 2
- I have already developed CAP to support the Dameng database. How can I submit it HOT 1
- Considering adding support for RocketMQ ? HOT 1
- Support for AWS Event Bridge
- Failed event may excute more than FailedRetryCount when EnableSubscriberParallelExecute is true HOT 4
- DotNetCore.CAP.Kafka consumer vulnerable to headerless messages HOT 2
- Feature request: identify and skip repeated messages HOT 1
- Feature Request: Supports publish-only or consume-only HOT 4
- DaMeng Database: DeleteExpiresAsync sql Datetime auto format AM/PM HOT 3
- Incorrect order of messages sent between version 7.2 and 8.1 HOT 2
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from cap.