Example code for accessing PDP API and PDP Kafka streams.
- Python 3.x
- pip3
pip3 install -r requirements.txt
python3 ./
./kafka-console-consumer.sh --bootstrap-server kafka.pdp.production.srgssr.ch:9095 --consumer.config ./kafka.consumer.properties --topic t-ebucore-programme-v14
- t-ebucore-programme-v14
- t-ebucore-document-v14
- t-ebucore-items-v14
- User: admin
- Password: Pdp-Test1
Note: kafka-console-consumer.sh runs without Avro schema deserialisation. For deserialising Avro messages use Avro deserialiser https://stackoverflow.com/questions/49927747/how-to-pass-parameters-for-a-specific-schema-registry-when-using-kafka-avro-cons