deser primitive avro

[raphaelauv]

with a primitive string avro schema for key

{"type": "string"}

how to reproduce :

  akhq:
    image: tchiotludo/akhq:0.17.0
    environment:
      AKHQ_CONFIGURATION: |
        akhq:
          connections:
            docker-kafka-server:
              properties:
                bootstrap.servers: "kafka-broker:29092"
              schema-registry:
                url: "http://schema-registry:8081"
    ports:
      - 9023:8080
      - 9024:8081

create a topic test_topic

produce a key schema for this topic with the schema-registry :

curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json" \
  --data '{"schema": "{\"type\": \"string\"}"}' \
  http://localhost:8081/subjects/test_topic-key/versions

produce an event in the topic with the key schema ( message value can be null )

there is a warning for message using the avro primitive schema ->

class java.lang.String cannot be cast to class org.apache.avro.generic.GenericRecord (java.lang.String is in module java.base of loader 'bootstrap'; org.apache.avro.generic.GenericRecord is in unnamed module of loader 'app')

[raphaelauv]

The visual problem of the key is only with google chrome !

not with firefox ->

the control-center of confluent have exactly the same problem with google chrome.

But there is still a warning with booth web browsers about the deser ->

[tchiotludo]

Can you provide the full stacktrace (if you have one) on the server logs ?

[raphaelauv]

if I set

image: tchiotludo/akhq:0.16.0

There is no more the WARN in the UI of booth web browsers, (but still the bug with google chrome on the print of the key)

So only since this 92d4ee8 commit the warning is visible in the UI

[raphaelauv]

We need to manage the primitive cases that do not return a GenericRecord ->

akhq/src/main/java/org/akhq/models/Record.java

Line 126 in 4e0e267

GenericRecord record = (GenericRecord) kafkaAvroDeserializer.deserialize(topic, payload);

this work , but it's not elegant and not full coverage of all primitives listed there -> https://stackoverflow.com/a/34234039

Object toType = kafkaAvroDeserializer.deserialize(topic, payload);

if (!(toType instanceof GenericRecord)){
    return String.valueOf(toType);
}

GenericRecord record = (GenericRecord) toType;