其他协同部门用的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插件吗?
https://cwiki.apache.org/confluence/display/KAFKA/Clients
里面有你需要的
感谢大神,国庆还在看问题,辛苦了
不好意思,我还是没有看到关于schema.registry的设置,有具体一点的吗?谢谢了
看来你要自己写了,官方php现在只到0.8版本的客户端。
PHP 0.8版本的kafka客户端还没有支持schema吗?所以要用avro就要另装扩展是吗?
嗯 连接器是0.9+的新功能。
好的,谢谢了
你的答案