BytesSerializer (kafka 2.8.1 API)

java.lang.Object
- org.apache.kafka.common.serialization.BytesSerializer

All Implemented Interfaces:: Closeable, AutoCloseable, Serializer<org.apache.kafka.common.utils.Bytes>

public class BytesSerializer
extends Object
implements Serializer<org.apache.kafka.common.utils.Bytes>

Constructor Summary

Constructors
Constructor Description

BytesSerializer()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`byte[]`	`serialize(String topic, org.apache.kafka.common.utils.Bytes data)`	Convert `data` into a byte array.

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

Methods inherited from interface org.apache.kafka.common.serialization.Serializer
close, configure, serialize

- Constructor Detail
  - BytesSerializer
```
public BytesSerializer()
```
- Method Detail
  - serialize
```
public byte[] serialize(String topic,
                        org.apache.kafka.common.utils.Bytes data)
```
    Description copied from interface: Serializer
    
    Convert data into a byte array.
    
    Specified by:
    
    serialize in interface Serializer<org.apache.kafka.common.utils.Bytes>
    
    Parameters:
    
    topic - topic associated with data
    
    data - typed data
    
    Returns:
    
    serialized bytes