Confluent REST Proxy

Documentation here

V1 Vs V2 APIs

• Just use V2 API
• Content-Type header should be specified as application/vnd.kafka.[embedded_format].[api_version]+[serialization_format]
  • embeddedformat: json, binary or avro
  • api_version is always v2
  • serialization_format is always json

Example: Content-Type: application/vnd.kafka.avro.v2+json

Port number is 8082 typically

Topic Operations

• Get a list of topics
• Get a specific topic

Can't create/configure topics with the REST Proxy

Producing in Binary with the Kafka REST Proxy

• Binary data has to be base64 encoded before sending it to Kafka

References

Flashcards

If I want to send binary data through the REST proxy to topic "test_binary", it needs to be base64 encoded. A consumer connecting directly into the Kafka topic "test_binary" will receive:: binary data

What data format isn't natively available with the Confluent REST Proxy?:: Protobuf

If I want to send binary data through the REST proxy, it needs to be base64 encoded. Which component needs to encode the binary data into base 64?:: The Producer. The REST Proxy requires to receive data over REST that is already base64 encoded, hence it is the responsibility of the producer