Consume FETCH ERROR when reading from topic
I have kafka cluster with 3 brokers inside kubernetes cluster. Empty topic with 1 partition created manualy via kafka ui app .NET consumer config (nuget package Confluent.Kafka Version=”2.5.1″) var config = new ConsumerConfig { BootstrapServers = _streamProviderOptions.BootstrapServers, GroupId = $”consumer-{_topicName}”, AutoOffsetReset = AutoOffsetReset.Earliest, EnableAutoCommit = false, EnablePartitionEof = true, ClientId = $”consumer-client-{_topicName}”, IsolationLevel = IsolationLevel.ReadCommitted […]
Serialize JsonDocument for Kafka Schema Registry if CLR type is Unknown
I am trying to serialize data of type JsonDocument to Kafka’s Schema Registry. Let’s assume that the data I am receiving is a JSON string, and I do not have the CLR type. I do not know the CLR type because it might be coming from another application.
How do I serialize a data for Kafka’s Schema Registry if the data is of type JsonDocument and CLR type is unknown
I am trying to serialize data which is of type JsonDocument to Kafka’s Schema Registry. Let’s assume that the data that I’m receiving is a Json string and I don’t have the CLR type.