Eugene Bikkinin

Offline workers remain in metrics

14

**Describe the bug** We are deploing celery workers in k8s. Flower instance is also deployed in a separate pod. After redeploy, when one pod is killed and new pod is...

I am not very familiar with Scala and SBT so my code change might be not optimal. But this version packaged with sbt-assembly as uber-jar works fine on Spark 3.1...

feat(filter_state): Added @api and @has_access_api to all methods of filter_state API.

1

### SUMMARY The API of filter_state is already exposed but it doesn't look like other APIs. We had a problem gaining 403 Status Code when addressing this endpoint. It was...

Add behaviors registration for certain request types

17

Hi! When I use MediatR I miss one important feature. I want to register **Behaviors** not only for certain **Request** and **Response** or for generic **TRequest** and **TResponse**. But I...

Inconsistent results in pull queries with distributed KsqlDB setup

1

### Setup First of all, we have 6 machines each containing its instance of running in Docker from the image `confluentinc/ksqldb-server v 0.29.0`. Second, we have this setup: ``` listeners=http://0.0.0.0:8088/...

Fix comments in config to make them consistent with docs and code.

2

### Description Current config samples contradict [the actual code](https://github.com/confluentinc/ksql/blob/f24ed0d2278665be00e29b7a7e1f04bd50f22c85/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/KsqlRestConfig.java#L183). I was confused what is the right settings and decided to fix samples to make them consistent with docs and code....

I'm trying to run this extension from VS Code. I set up my configuration: ``` { "version": "0.2.0", "configurations": [ { "type": "ruby-debug", "request": "launch", "name": "RSpec (Active File)", "program":...