apache-kafka

Similar how consumer group (offsets) can be deleted Topics should be deletable in Kowl as well.

Please create ingress template and configuration for:

• kafka-rest
• kafka-connect
• schema-registry

Add replicas field in partitions table at topic overview page.
We can get list of replicas from topic request endpoint: /clusters/{clusterName}/topics/{topicName}

{
    "name": "name",
    "internal": true,
    "partitions": [
        {
            "partition": 0,
            "leader": 2,
            "replicas": [
                {
                    "broker": 2,
          

If for some reason a user starts up a broker outside of the web client, they should be able to make a new GET request to the backend to update the broker list in the client.

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