APISonar


io.confluent.kafkarest.entities.EmbeddedFormat.JSON

> io > confluent > kafkarest > entities > EmbeddedFormat > JSON
io APIs confluent APIs kafkarest APIs entities APIs EmbeddedFormat APIs JSON APIs

Example 1
public void testConsumeOnlyValues() {
    String instanceUri = startConsumeMessages(groupName, topicName, EmbeddedFormat.JSON,
        Versions.KAFKA_V1_JSON_JSON);
    produceJsonMessages(recordsOnlyValues);
    consumeMessages(instanceUri, topicName, recordsOnlyValues,
        Versions.KAFKA_V1_JSON_JSON, Versions.KAFKA_V1_JSON_JSON,
        jsonConsumerRecordType, null);
    commitOffsets(instanceUri);
  }
Example 2
public void produceJson(
      final @Suspended AsyncResponse asyncResponse,
      @PathParam("topic") String topicName,
      @Valid @NotNull TopicProduceRequest<JsonTopicProduceRecord> request
  ) {
    produce(asyncResponse, topicName, EmbeddedFormat.JSON, request);
  }