php远程调用kafka服务,可以配置schema.registry.url吗?怎么配置?

superman 发表于: 2018-09-30   最后更新时间: 2018-10-01 23:09:36   3,798 游览

其他协同部门用的java,有设置:

Properties props = new Properties();
props.put("schema.registry.url", SCHEMA_REGISTRY_URL);
Producer<String, Order> OrderProducer = new KafkaProducer<>(props);

我用php远程调用kafka服务,要怎么配置schema?要装php-avro插件吗?

发表于 2018-09-30
添加评论
superman -> 半兽人 6年前

感谢大神,国庆还在看问题,辛苦了

superman -> 半兽人 6年前

不好意思,我还是没有看到关于schema.registry的设置,有具体一点的吗?谢谢了

半兽人 -> superman 6年前

看来你要自己写了,官方php现在只到0.8版本的客户端。

superman -> 半兽人 6年前

PHP 0.8版本的kafka客户端还没有支持schema吗?所以要用avro就要另装扩展是吗?

半兽人 -> superman 6年前

嗯 连接器是0.9+的新功能。

superman -> 半兽人 6年前

好的,谢谢了

你的答案

查看kafka相关的其他问题或提一个您自己的问题