Kafka权威指南（第2版）

Kafka

消费者——从

Kafka

读取数据

｜

81

4.10.1

　自定义反序列化器

下面以在第

3

章中使用过的自定义对象为例，为它开发一个反序列化器。

public class Customer {

private int customerID;

private String customerName;

public Customer(int ID, String name) {

this.customerID = ID;

this.customerName = name;

}

public int getID() {

return customerID;

}

public String getName() {

return customerName;

}

}

自定义反序列化器如下所示。

import org.apache.kafka.common.errors.SerializationException;

import java.nio.ByteBuffer;

import java.util.Map;

public class CustomerDeserializer implements Deserializer<Customer> {

➊

@Override

public void configure(Map configs, boolean isKey) {

// 不需要做任何配置

}

@Override

public Customer ...