EventStreamsDeserializer (IBM Event Streams schema registry serdes API)

Skip navigation links

Prev Class
Next Class

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

java.lang.Object
- com.ibm.eventstreams.serdes.EventStreamsDeserializer

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.serialization.Deserializer<org.apache.avro.generic.IndexedRecord>
```
public class EventStreamsDeserializer
extends Object
implements org.apache.kafka.common.serialization.Deserializer<org.apache.avro.generic.IndexedRecord>
```
The Event Streams deserializer used by Kafka to convert bytes to generic or specific IndexedRecord objects, using schemas retrieved from the schema registry.

Constructor Summary

Constructors
Constructor and Description

EventStreamsDeserializer()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`close()`
`void`	`configure(Map<String,?> configs, boolean isKey)`
`org.apache.avro.generic.IndexedRecord`	`deserialize(String topic, byte[] data)`
`org.apache.avro.generic.IndexedRecord`	`deserialize(String topic, org.apache.kafka.common.header.Headers headers, byte[] data)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - EventStreamsDeserializer
```
public EventStreamsDeserializer()
```
- Method Detail
  - configure
```
public void configure(Map<String,?> configs,
                      boolean isKey)
```
    Specified by:
    
    configure in interface org.apache.kafka.common.serialization.Deserializer<org.apache.avro.generic.IndexedRecord>
  - deserialize
```
public org.apache.avro.generic.IndexedRecord deserialize(String topic,
                                                         byte[] data)
```
    Specified by:
    
    deserialize in interface org.apache.kafka.common.serialization.Deserializer<org.apache.avro.generic.IndexedRecord>
  - deserialize
```
public org.apache.avro.generic.IndexedRecord deserialize(String topic,
                                                         org.apache.kafka.common.header.Headers headers,
                                                         byte[] data)
```
    Specified by:
    
    deserialize in interface org.apache.kafka.common.serialization.Deserializer<org.apache.avro.generic.IndexedRecord>
  - close
```
public void close()
```
    Specified by:
    
    close in interface Closeable
    
    Specified by:
    
    close in interface AutoCloseable
    
    Specified by:
    
    close in interface org.apache.kafka.common.serialization.Deserializer<org.apache.avro.generic.IndexedRecord>