apache-kafka

On main ksql page there's a list of streams/tables, they're currently a part of the same table. Let's separate them by tabs

We are using the protobuf-git configuration as described at https://cloudhut.dev/docs/features/protobuf#git-repository
In our repository the proto-files live within a proto directory, which seems to be very common, and contains 5 levels of nested folders.

Currently KOWL searches only the first 5 levels of the checkout for .proto files, so our last level is not considered.

• Please

Please create ingress template and configuration for:

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

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.

Converting timestamp to topic/partition offset is not easy without coding.... a nice new feature would be to be able to consume messages by providing from-timestamp, and let the kafkactl code compute the corresponding start offset value.

The sum and count Kafka tutorials instruct the user to create a directory called aggregate-, whereas the actual folder for them in GitHub are called aggregating-.

There is no functional impact to current behavior (it still works) but it would be better to be consistent.

Hi Team,

Am getting timeouts for kcctl describe connector * or kcctl get connectors
Let me know how I can increase timeout

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

Currently, both Kafka and Influx sink logs only the data(Row) that is being sent.

Add support for logging column names as well along with data points similar to the implementation in log sink.

This will enable users to correlate the data points with column names.