Dapr pubsub tried to use a consumer group that was closed
- Dominant language
- C#
- Stars
- 1.2k
- Forks
- 378
- Avg merge
- 2d 1h
- Merged PRs (30d)
- 6
Description
## Ask your question here
Hello,
I'm using Dapr for sending and receiving messages from kafka with .net. I have an multiple controller for multiple topics. When starting application in kubernates then it has bellow error. If dapr subscribe single topic, then everything is ok but multiple topic subscriptions has an exception has occured. How can I solve this issue? Any suggestion for this?
level=info msg="app is subscribed to the following topics: [Topic1 Topic 2] through pubsub=........."
level=error msg="Error consuming [Topic1]. Retrying...: kafka: tried to use a consumer group that was closed"
**Contoller 1:**
public class Topic1Controller : ControllerBase
{
[Topic("pubsub-name", "Topic1")]
public Task HandleAsync(Topic1Event @event)
{
return Task.CompletedTask;
}
}
**Controller 2:**
public class Topic2Controller : ControllerBase
{
[Topic("pubsub-name", "Topic2")]
public Task HandleAsync(Topic2Event @event)
{
return Task.CompletedTask;
}
}
Contributor guide
Research direction
Start with the two controller entry points and the Kafka pubsub subscription setup used by the Dapr .NET application. Reproduce the Kubernetes case with Topic1 and Topic2 subscribed together, then compare it with a single-topic subscription. Done means both topics consume successfully without the “consumer group that was closed” error.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- csharp, kafka, kubernetes
- Domain
- backend, distributed-systems
- Issue type
- Bug
- Difficulty
- 5/5
- Estimated time
- Over a week
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 20/100