Would be great to push a docker image with each PR raised/changed. Would be of great help in testing out the PR.

Devise and implement a way for topic partitions (on the page consumer-groups/{consumer-group-name}) to be visually grouped by topic.

Catch all is right now pushing error to sentry. Would like to publish the same to new relic as well. Planning to use noticeError provided by newrelic java agent.

Add some integration tests including the use of an avro schema registry

Is your feature request related to a problem? Please describe.
Today the user needs to deploy udf jars and reference data csvs manually to the blob location

Describe the solution you'd like
Enable the user to choose a file on a local disk which the web portal will then upload to the right location

Description

Add some integration tests with dotnet testcontainers library

Use Case

• Provide a sample application to test DBs, messaging systems and HTTP, GRPC backend resolution and call view.

Proposal

• A simple app where backend can be swapped or we can use multiple backends.

wrt existing tutorial at https://kafka-tutorials.confluent.io/how-to-count-messages-on-a-kafka-topic/ksql.html

Add limitation that when there are a large number of records in the topic (i.e., hundreds of millions of records), this query can take a very long time to finish (i.e., tens of minutes, sometime few hours)

Currenlty a StreamsExecutionEnvironment instance can be registed directly through the AzkarraContext#addExecutionEnvironment method and from the configuration.

The following example shows how to define an environment using configuration :

azkarra {
  // Create a environment for running the WordCountTopology
  environments = [
    {
      name: "dev"
      config = {}
      jo