In this section, we will learn how to configure the Dashboard.
KafkaFlow provides a Dashboard where you can visualize information related to your consumers and use all operations available on KafkaFlow.Admin.WebApi.
caution
It is important to note that the Dashboard runs, shows information, and manages the consumers on all application instances. This means that if you have 10 machines running your application, the Dashboard will run in every instance. Any operation will affect the consumer in all the machines.
You can configure the Dashboard during the configuration, as shown in the following example (built using .NET 6).
using KafkaFlow;
using KafkaFlow.Admin.Dashboard;
var builder = WebApplication.CreateBuilder(args);
builder.Services
.AddKafka(kafka => kafka
.AddCluster(cluster => cluster
.WithBrokers(new[] { "localhost:9092" })
.AddConsumer(consumer => consumer
.Topic("mytopic")
.WithGroupId("g1")
.WithWorkersCount(1)
.WithBufferSize(10)
)
.EnableAdminMessages("kafka-flow.admin")
.EnableTelemetry("kafka-flow.admin")
))
.AddControllers();
var app = builder.Build();
app.MapControllers();
app.UseKafkaFlowDashboard();
var kafkaBus = app.Services.CreateKafkaBus();
await kafkaBus.StartAsync();
await app.RunAsync();
The dashboard UI will be available at /kafkaflow and is refreshed every 5 seconds with telemetry data available at the endpoint /kafkaflow/consumers/telemetry.
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4