masesgroup/KEFCore

StreamResetter shall be invoked to cleanup what was stored in Apache Kafka Streams

Closed this issue · 0 comments

masesdevelopers commented

Describe the bug
When the application is restarted, using the same ApplicationId, previously stored data in Apache Kafka Streams can impact the behavior of the application.

To Reproduce
Steps to reproduce the behavior:

  1. Change the test program adding/removing some values at the end of the current queries (e.g. add 100 items)
  2. Execute the test program
  3. Execute again the test program
  4. The following trace does not report the current values (expected 1000), but reports something like KafkaEnumerator - ApproximateNumEntries 1100 which means the stream application had stored the latest test done

Expected behavior
The stream application shall be resetted before

KEFCore/test/KEFCore.Test/Program.cs

Line 60 in 6c01278

context.Database.EnsureDeleted();
is invoked.
This can be done manually from command-line or KNet shall be enhanced to do that programmatically.

Screenshots
If applicable, add screenshots to help explain your problem.

Desktop (please complete the following information):

  • Latest KEFCore version

Additional context
N/A