EventStreamsSerializer (IBM Event Streams schema registry serdes API)

Skip navigation links

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

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

All Implemented Interfaces:

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

Constructor Summary

Constructors
Constructor and Description

EventStreamsSerializer()

Method Summary

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

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

- Constructor Detail
  - EventStreamsSerializer
```
public EventStreamsSerializer()
```
- Method Detail
  - configure
```
public void configure(Map<String,?> configs,
                      boolean isKey)
```
    Specified by:
    
    configure in interface org.apache.kafka.common.serialization.Serializer<org.apache.avro.generic.IndexedRecord>
  - serialize
```
public byte[] serialize(String topic,
                        org.apache.avro.generic.IndexedRecord data)
```
    Specified by:
    
    serialize in interface org.apache.kafka.common.serialization.Serializer<org.apache.avro.generic.IndexedRecord>
  - serialize
```
public byte[] serialize(String topic,
                        org.apache.kafka.common.header.Headers headers,
                        org.apache.avro.generic.IndexedRecord data)
```
    Specified by:
    
    serialize in interface org.apache.kafka.common.serialization.Serializer<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.Serializer<org.apache.avro.generic.IndexedRecord>