The guide explains how to inspect consumer using Kafka CLI.
Find running Kafka container:
> docker ps | grep kafkaEnter your Kafka (docker) container:
| namespace DotNet8Starter.DL.Models | |
| { | |
| public class ExcelResponse | |
| { | |
| public string Name { get; set; } | |
| public byte[] Data { get; set; } | |
| public static ExcelResponse ToResponse(string name, byte[] data) | |
| { | |
| return new ExcelResponse() |
| public class AppLogger<T> : IAppLogger<T> where T : class | |
| { | |
| private readonly ILogger<T> _logger; | |
| public AppLogger(ILogger<T> logger) | |
| { | |
| _logger = logger; | |
| } |
| using TestingPractice.Services; | |
| namespace TestingPractice | |
| { | |
| public class Program | |
| { | |
| public static void Main(string[] args) | |
| { | |
| var builder = WebApplication.CreateBuilder(args); |
| using APIDocsRider.DB; | |
| using Microsoft.Data.SqlClient; | |
| using Microsoft.EntityFrameworkCore; | |
| namespace APIDocsRider.BL; | |
| public class WorkerService(ILogger<WorkerService> logger, IServiceProvider serviceProvider) : BackgroundService | |
| { | |
| private readonly IServiceProvider _serviceProvider = serviceProvider; | |
| private readonly ILogger<WorkerService> _logger = logger; |