Change the register REST API to accept just the schema string

README.md

@@ -16,14 +16,7 @@ Quickstart
 
 4. Register a schema
 curl -v -H "Content-Type: application/vnd.schemaregistry.v1+json" -X POST -i http://localhost:8080/topics/Kafka/value/versions -d '
- {"schema":{
-   "name": "Kafka",
-   "version": 1,
-   "schema": "Hello World",
-   "compatible": true,
-   "deprecated": false,
-   "latest": true
- }}'
+ {"schema":"Hello World"}'
 
 5. List all topics
 curl -v -H "Content-Type: application/vnd.schemaregistry.v1+json" -X GET http://localhost:8080/topics

src/main/java/io/confluent/kafka/schemaregistry/rest/entities/requests/RegisterSchemaRequest.java

@@ -6,15 +6,15 @@
 
 public class RegisterSchemaRequest {
     @NotEmpty
-    private Schema schema;
+    private String schema;
 
     @JsonProperty("schema")
-    public Schema getSchema() {
+    public String getSchema() {
         return this.schema;
     }
 
     @JsonProperty("schema")
-    public void setSchema(Schema schema) {
+    public void setSchema(String schema) {
         this.schema = schema;
     }
 

src/main/java/io/confluent/kafka/schemaregistry/rest/resources/SchemasResource.java

@@ -62,7 +62,8 @@ public List<Integer> list() {
     @POST
     public void register(final @Suspended AsyncResponse asyncResponse,
         @PathParam("topic") String topicName, RegisterSchemaRequest request) {
-        int version = schemaRegistry.register(topicName, request.getSchema());
+        Schema schema = new Schema(topicName, 0, request.getSchema(), true, false, true);
+        int version = schemaRegistry.register(topicName, schema);
         RegisterSchemaResponse registerSchemaResponse = new RegisterSchemaResponse();
         registerSchemaResponse.setVersion(version);
         asyncResponse.resume(registerSchemaResponse);

src/main/java/io/confluent/kafka/schemaregistry/storage/SchemaRegistry.java

@@ -60,6 +60,7 @@ public int register(String topic, Schema schema) {
         if (isCompatible(topic, schema, latestSchema)) {
             try {
                 schema.setVersion(version);
+                System.out.println("Adding schema to the Kafka store: " + schema.toString());
                 kafkaStore.put(newKeyForLatestSchema, schema);
             } catch (StoreException e) {
                 e.printStackTrace();