接收消息必须指定序列化实现类,可使用内置DefDes构造long/int/double/String/ByteBuffer/byte[]类型的反序列化:
Deserializer<String> des = new DefDes<String>(String.class);
KafkaAPI<String, String> api = SDK.getCCAPI().getKafkaAPI(profileId , des , des);
api.topic("topic").send("test");