Kafka Streams： DeseriazationExceptionHandler与配置参数
我不熟悉反射Java。MyCustomExcpse类实现了DeseriazationExceptionHandler接口和在流配置，我知道类可以提供。但是，有没有办法提供配置（在配置方法中）与类？你能提供一个示例代码吗？
streamsConfig.put(StreamsConfig.DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG, MyCustomException.class);
.
public class MyCustomException implements DeserializationExceptionHandler {
@Override
public void configure(Map<String, ?> configs) {
}
共有1个答案
传入的映射
-
类名 \Yurun\PaySDK\AlipayApp\Params\PublicParams 属性 名称 类型 说明 $format string 仅支持JSON $charset string 请求使用的编码格式，如utf-8,gbk,gb2312等 $sign_type string 商户生成签名字符串所使用的签名算法类型，目前支持RSA2和RSA，推荐使用RSA2。 RSA2需要PHP版本>
-
类名 \Yurun\PaySDK\Weixin\Params\PublicParams 属性 名称 类型 说明 $sub_appid string 微信分配的子商户公众账号ID，服务商、银行服务商需要。 $mch_id string 微信支付分配的商户号 $sub_mch_id string 微信支付分配的子商户号，开发者模式下必填，服务商、银行服务商需要。 $sign_type string 签
-
类名 \Yurun\PaySDK\Alipay\Params\PublicParams 属性 名称 类型 说明 $_input_charset string 商户网站使用的编码格式，如UTF-8、GBK、GB2312等。 $sign_type string DSA、RSA、MD5三个值可选，必须大写。 $appPrivateKey string 应用私有证书文件内容 $appPrivateKeyF
-
In addition to instructing the platform which test classes and test engines to include, which packages to scan, etc., it is sometimes necessary to provide additional custom configuration parameters th
-
beego 目前支持 INI、XML、JSON、YAML 格式的配置文件解析，但是默认采用了 INI 格式解析，用户可以通过简单的配置就可以获得很大的灵活性。 默认配置解析 beego 默认会解析当前应用下的 conf/app.conf 文件。 通过这个文件你可以初始化很多 beego 的默认参数： appname = beepkg httpaddr = "127.0.0.1" httpport
-
Dorado提供下列的参数配置 1.调用端配置 配置参数 含义 默认值 说明 必配配置 appkey 调用端appkey remoteAppkey 服务端appkey serviceInterface 服务接口 接口的全限定名，不包括iface registry 服务发现配置 服务注册说明 可选配置 protocol 协议类型 thrift 默认OCTO协议 + Thrift协议 serializ