Create a topic
Let’s create a topic named “test” with a single partition and only one replica:
1 | > bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test |
关键要点:
使用响应式编程,就必须转变对给定问题的推理方式,因为我们要聚焦于作为事件流的流动数据,而非个别数据项。事件通常是被不同的线程所产生和消费,因此在编写测试时必须要对并发问题有着清晰的认识。幸运的是,RxJava 提供了测试 Observable
和 Subscription
的内建支持,并且是直接构建于 RxJava
的核心依赖中。
Generate openssl key
1 | ssh-keygen -t rsa -b 2048 -C "devg@nroad.com.cn" -f mars-jwt-rs256.key |
Generate certificate
1 | openssl req -newkey rsa:2048 -nodes -keyout key.pem -x509 -days 3650 -out certificate.pem -key mars-jwt-rs256.key |
Export private key and certificate to pkcs12 key store
1 | openssl pkcs12 -export -name mars-jwt-cert -in certificate.pem -inkey mars-jwt-rs256.key -out mars-jwt-rs256.p12 |
Import from pkcs12 keystore to java key store
1 | keytool --importkeystore --destkeystore mars.jks -srckeystore mars-jwt-rs256.p12 -srcstoretype pkcs12 -alias mars-jwt-cert |
(Optional) Convert imported java keystore to pkcs12 type
1 | keytool -importkeystore -srckeystore mars.jks -destkeystore mars.jks -deststoretype pkcs12 |
Export public key from private key
1 | openssl rsa -pubout -in mars-jwt-rs256.key > mars-jwt.pub |