Package org.springframework.pulsar.core

Class SchemaUtils

java.lang.Object

org.springframework.pulsar.core.SchemaUtils

public final class SchemaUtils
extends Object

Utility class for Pulsar schema inference.

Author:

Soby Chacko, Alexander Preuß

Method Summary

Modifier and Type	Method	Description
static <T> org.apache.pulsar.client.api.Schema<T>	getSchema(Class<?> messageClass)
static <T> org.apache.pulsar.client.api.Schema<T>	getSchema(Class<?> messageClass, boolean returnDefault)
static <T> org.apache.pulsar.client.api.Schema<T>	getSchema(T message)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getSchema

public static <T>
org.apache.pulsar.client.api.Schema<T> getSchema(T message)

getSchema

public static <T>
org.apache.pulsar.client.api.Schema<T> getSchema(Class<?> messageClass)

getSchema

public static <T>
org.apache.pulsar.client.api.Schema<T> getSchema(Class<?> messageClass,
 boolean returnDefault)