Class Hierarchy
- java.lang.Object
- io.deephaven.kafka.publish.GenericRecordKeyOrValueSerializer (implements io.deephaven.kafka.publish.KeyOrValueSerializer<SERIALIZED_TYPE>)
- io.deephaven.kafka.publish.JsonKeyOrValueSerializer (implements io.deephaven.kafka.publish.KeyOrValueSerializer<SERIALIZED_TYPE>)
- io.deephaven.util.referencecounting.ReferenceCounted (implements io.deephaven.base.log.LogOutputAppendable)
- io.deephaven.engine.liveness.ReferenceCountedLivenessReferent (implements io.deephaven.engine.liveness.LivenessReferent)
- io.deephaven.engine.liveness.ReferenceCountedLivenessNode (implements io.deephaven.engine.liveness.LivenessNode)
- io.deephaven.engine.liveness.LivenessArtifact (implements java.io.Serializable)
- io.deephaven.kafka.publish.PublishToKafka<K,
V>
- io.deephaven.kafka.publish.PublishToKafka<K,
- io.deephaven.engine.liveness.LivenessArtifact (implements java.io.Serializable)
- io.deephaven.engine.liveness.ReferenceCountedLivenessNode (implements io.deephaven.engine.liveness.LivenessNode)
- io.deephaven.engine.liveness.ReferenceCountedLivenessReferent (implements io.deephaven.engine.liveness.LivenessReferent)
- io.deephaven.kafka.publish.SimpleKeyOrValueSerializer<SERIALIZED_TYPE> (implements io.deephaven.kafka.publish.KeyOrValueSerializer<SERIALIZED_TYPE>)
- java.lang.Throwable (implements java.io.Serializable)
- java.lang.Exception
- java.lang.RuntimeException
- io.deephaven.UncheckedDeephavenException
- io.deephaven.kafka.publish.KafkaPublisherException
- io.deephaven.UncheckedDeephavenException
- java.lang.RuntimeException
- java.lang.Exception
Interface Hierarchy
- java.lang.AutoCloseable
- io.deephaven.util.SafeCloseable
- io.deephaven.kafka.publish.KeyOrValueSerializer.Context
- io.deephaven.util.SafeCloseable
- io.deephaven.kafka.publish.KeyOrValueSerializer<SERIALIZED_TYPE>