接入说明
Region | 域名 |
公网 | kafka-ons-internet.aliyun.com:8080 |
华东1 | kafka-cn-hangzhou.aliyun.com:8080 |
华北2 | kafka-cn-beijing.aliyun.com:8080 |
华东2 | kafka-cn-shanghai.aliyun.com:8080 |
华南1 | kafka-cn-shenzhen.aliyun.com:8080 |
参数 | 值 |
bootstrap.servers | 请根据 region 进行选择 |
ssl.truststore.location | /home/admin/kafka.client.truststore.jks(请注意修改为自己的路径) |
ssl.truststore.password | KafkaOnsClient |
security.protocol | SASL_SSL |
sasl.mechanism | ONS |
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
您已经详细描述了如何使用Java接入阿里云的Kafka服务(MQ-Kafka),这里我再简要概括一下关键步骤,确保您能顺利实施:
申请资源:
确认版本兼容性:
查看并参考Demo:
Maven依赖配置:
鉴权配置:
kafka_client_jaas.conf
文件,填入AccessKey和SecretKey进行鉴权。根证书下载与配置:
主要参数配置:
运行Demo:
run_demo.sh
启动Demo,记得替换脚本中的Topic名称为您实际申请的Topic。检查结果:
如果在接入过程中遇到任何问题,可以考虑加入阿里云提供的钉钉群咨询,获取更直接的技术支持。希望这些步骤能帮助您顺利完成阿里云Kafka服务的接入工作。