Uses of Class
com.networknt.kafka.producer.RegisteredSchema
-
-
Uses of RegisteredSchema in com.networknt.kafka.producer
Methods in com.networknt.kafka.producer that return RegisteredSchema Modifier and Type Method Description RegisteredSchemaSchemaManager. getSchema(String topicName, Optional<EmbeddedFormat> format, Optional<String> subject, Optional<io.confluent.kafka.serializers.subject.strategy.SubjectNameStrategy> subjectNameStrategy, Optional<Integer> schemaId, Optional<Integer> schemaVersion, Optional<String> rawSchema, boolean isKey)Returns aschemamatching the parameter options.RegisteredSchemaSchemaManagerImpl. getSchema(String topicName, Optional<EmbeddedFormat> format, Optional<String> subject, Optional<io.confluent.kafka.serializers.subject.strategy.SubjectNameStrategy> subjectNameStrategy, Optional<Integer> schemaId, Optional<Integer> schemaVersion, Optional<String> rawSchema, boolean isKey)Method parameters in com.networknt.kafka.producer with type arguments of type RegisteredSchema Modifier and Type Method Description Optional<com.google.protobuf.ByteString>SchemaRecordSerializer. serialize(EmbeddedFormat format, String topicName, Optional<RegisteredSchema> schema, com.fasterxml.jackson.databind.JsonNode data, boolean isKey)
-