KafkaOnsDemo

Demo跑起来

1. 添加自己的AccessKey，SecretKey到src/main/resources/kafka_client_jaas.conf中

2. 在ONS控制台申请Topic，类型选择"Kafka消息(公测中)", 这里假定为kafka-test(该Topic很有可能已经被别人申请，请修改为自己定义的名字)

3. 执行

   sh run_demo.sh -Dkafka.ons.TOPIC=kafka-test

4. 看到结果如下表示成功(注意，第一次创建topic可能需要点时间，如遇失败，请间隔一定时间多试几次)

   produce ok:kafka-test-*

接入说明

用户可以利用Kafka Client去收发Ons的消息，使用之前请先阅读以下规约：

1. Kafka Client版本需要0.10及以上
2. 使用之前需要先申请Topic(类型选择Kafka消息(公测中)), 与Consumer ID，详情请参考申请MQ资源
3. 如果没有申请Topic，则会直接导致鉴权失败
4. 其它Kafka使用相关文档请参考Kafka官网
5. 欢迎加钉钉群咨询，用钉钉扫描群二维码

接入步骤一：引入依赖

Maven方式：

<dependency>
     	<groupId>org.apache.kafka</groupId>
     	<artifactId>kafka-clients</artifactId>
     	<version>0.10.0.0</version>
</dependency>
<dependency>
<groupId>com.aliyun.openservices</groupId>
    	<artifactId>ons-sasl-client</artifactId>
    	<version>0.1</version>
</dependency>

接入步骤二：配置AccessKey，SecretKey

Kafka利用AccessKey，SecretKey对通道进行鉴权 新建一个文本文件名为kafka_client_jaas.conf，内容如下(记得把XXX替换为自身的AccessKey，SecretKey)：

KafkaClient {
com.aliyun.openservices.ons.sasl.client.OnsLoginModule required
AccessKey="XXX"
SecretKey="XXX";
};

放置在某个目录下，这里假定为/home/admin 然后在程序启动的时候，配置

-Djava.security.auth.login.config=/home/admin/kafka_client_jaas.conf

或者直接在代码中设置（需要保证在Kafka Producer和Consumer启动之前):

System.setProperty("java.security.auth.login.config", “/home/admin/kafka_client_jaas.conf");

接入步骤三：下载根证书

证书truststore下载地址

将证书放置在某个目录下，这里假定为/home/admin

接入步骤四：配置参数

对于Kafka Producer和Consumer都需要以下几个配置：

参数	值
bootstrap.servers	SASL_SSL://kafka-ons-internet.aliyun.com:8080
ssl.truststore.location	/home/admin/kafka.client.truststore.jks
ssl.truststore.password	KafkaOnsClient
security.protocol	SASL_SSL
sasl.mechanism	ONS

注意/home/admin要改为自己的目录

其它Kafka参数遵照官网说明即可