alteest

Results 2 issues of alteest

Support k8s gracefully shutdown and wait current message processing **Is your feature request related to a problem? Please describe.** When k8s decided to stop pod it send SIGTERM and FasStream...

enhancement

**Describe the bug** Use consumer to get data from Kafka and it's read not all data. It goes to zero and then grows up to ~4k (I suppose it depend...

bug