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

Exception that internally created topics exist #391

Open
8 tasks
neterror opened this issue Nov 29, 2024 · 0 comments
Open
8 tasks

Exception that internally created topics exist #391

neterror opened this issue Nov 29, 2024 · 0 comments
Labels
bug Something isn't working
Milestone

Comments

@neterror
Copy link

neterror commented Nov 29, 2024

Description

I created a simple stream app that:

  • subscribe to a stream
  • change the key of the stream
  • create a table from the stream

On the first time that I start the app, there is an exception that internally created topic already exists. On the next run the program starts without exception

How to reproduce

        var builder = new StreamBuilder();
        builder.Stream<string, MeasuredValue, StringSerDes, Proto<MeasuredValue>>(KTopicValues)
            .SelectKey((key, value) => $"{key}-{value.Read}")
            .ToTable(InMemory.As<string, MeasuredValue>("values.store").WithValueSerdes<Proto<MeasuredValue>>());
        var topology = builder.Build();
        using var stream = new KafkaStream(topology, _config);
        await stream.StartAsync(stoppingToken);

result:

fail: Streamiz.Kafka.Net.KafkaStream[0]
      stream-application[testapp] Error during initializing internal topics
      Streamiz.Kafka.Net.Errors.StreamsException: An error occurred creating topics: [testapp-values.store-changelog]: [Topic 'testapp-values.store-changelog' already exists.].
       ---> Confluent.Kafka.Admin.CreateTopicsException: An error occurred creating topics: [testapp-values.store-changelog]: [Topic 'testapp-values.store-changelog' already exists.].

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.
  • A code snippet with your topology builder (ex: builder.Stream<string, string>("topic").to("an-another-topic");)
  • Streamiz.Kafka.Net nuget version.
  • Apache Kafka version.
  • Client configuration.
  • Operating system.
  • Provide logs (with in debug mode (log4net and StreamConfig.Debug) as necessary in configuration).
  • Critical issue.
@LGouellec LGouellec added the bug Something isn't working label Dec 6, 2024
@LGouellec LGouellec added this to the 1.8.0 milestone Dec 6, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working
Projects
None yet
Development

No branches or pull requests

2 participants