Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Failed to fetch committed offsets for partitions in #2240

Open
2 tasks
yeyijin opened this issue Jun 28, 2024 · 3 comments
Open
2 tasks

Failed to fetch committed offsets for partitions in #2240

yeyijin opened this issue Jun 28, 2024 · 3 comments

Comments

@yeyijin
Copy link

yeyijin commented Jun 28, 2024

Description

I use new topic and group. The topic has 10 partitions , but no message. The first consumer starts normally and is ready to consume as soon as there is news. 10 minutes later, the second consumer starts, but prompts

Confluent.Kafka.ConsumeException: Failed to fetch committed offsets for partitions in group "my_group": Local: Broker transport failure
at Confluent.Kafka.Consumer2.Consume(Int32 millisecondsTimeout) at Confluent.Kafka.Consumer2.Consume(CancellationToken cancellationToken)

Thanks.
How to reproduce

Checklist

Please provide the following information:

  • A complete (i.e. we can run it), minimal program demonstrating the problem. No need to supply a project file.
  • Confluent.Kafka nuget version. Version=2.2.0.0
@yeyijin
Copy link
Author

yeyijin commented Jun 28, 2024

 var consumerConfig = new ConsumerConfig
 {
     BootstrapServers = host,
     AutoOffsetReset = AutoOffsetReset.Latest,//消费最新
     GroupId = group,
     EnableAutoOffsetStore = true,
     EnableAutoCommit = true,

 };

while (!stoppingToken.IsCancellationRequested)
{
    try
    {
        var msg = _consumer.Consume(stoppingToken);
   }
  catch (Exception ex)
  {
  }
}

@anchitj
Copy link
Member

anchitj commented Jul 2, 2024

Can you provide debug logs?

@yeyijin
Copy link
Author

yeyijin commented Jul 11, 2024

ERROR|rdkafka#consumer-4| [thrd:app]: rdkafka#consumer-4: xxx.BootstrapServers.com:9092/bootstrap: Disconnected (after 5802ms in state UP)
CLUSTERID|rdkafka#consumer-4| [thrd:main]: Broker GroupCoordinator/203 reports different ClusterId "856HD-OddfsfsdddItOQ" than previously known "HuNdfsdfsdf6Etszzfd3PA": a client must not be simultaneously connected to multiple clusters
FAIL|rdkafka#consumer-4| [thrd:GroupCoordinator]: GroupCoordinator: 172.1.1.12:19092: Disconnected (after 6212ms in state UP)
ERROR|rdkafka#consumer-4| [thrd:app]: rdkafka#consumer-4: GroupCoordinator: 172.1.1.12:19092: Disconnected (after 6212ms in state UP)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants