dapr / dapr/dotnet-sdk

Dapr pubsub tried to use a consumer group that was closed

Open
#1,156 5 comments 0 reactions 0 assignees View on GitHub
area/client/pubsub question
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

Open the contributing 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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.