Package com.networknt.kafka.common
-
Interface Summary Interface Description Command Command is similar to the request in the request/response but it is asynchronous through Kafka.Event Base interface for event sourcing eventsMessage Message is the primary data object send to the Kafka topic with payload the describe the data. -
Class Summary Class Description AbstractAvroDeserializer AbstractAvroSerDe AbstractAvroSerializer AvroConverter AvroDecoder AvroDeserializer AvroSchemaUtils AvroSerializer CircularFifoQueue<E> CircularFifoQueue is a first-in first-out queue with a fixed size that replaces its oldest element if full.EventId EventId.Builder RecordBuilder for EventId instances.EventNotification FlinkKafkaProducer<K,V> Wrapper around KafkaProducer that allows to resume transactions in case of node failure, which allows to implement two phase commit algorithm for exactly-once semantic FlinkKafkaProducer.JsonPOJODeserializer<T> JsonPOJOSerializer<T> KafkaConsumerConfig KafkaProducerConfig A Kafka setting configuration file.KafkaStreamsConfig NonRecordContainer Wrapper for all non-record types that includes the schema for the data.SchemaRegistryConfig TransactionalIdsGenerator Class responsible for generating transactional ids to use when communicating with Kafka. -
Exception Summary Exception Description TransactionalKafkaException