AniketSaki

{
  "$schema": "http://json-schema.org/draft-07/schema#",
  "version": "1.0.0",
  "description": "Detailed BPP adapter transformation spec: maps Beckn v2 BAP action calls to proprietary seller API calls and defines how to build each on_* callback payload.",
  "notation": {
    "$in.<path>": "Field from the inbound Beckn action payload (after ACK is sent)",
    "$step<N>.<path>": "Field from the response of the Nth seller API call in the current action",
    "$state.<key>": "Value from adapter's per-transaction state store (keyed on context.transaction_id)",
    "$config.<key>": "Static seller/adapter configuration value",
    "$fn.now()": "Current ISO-8601 UTC timestamp",

AniketSaki

Apache-Python with Kafka source and sink

Reproduced from https://thecodinginterface.com/blog/kafka-source-sink-with-apache-flink-table-api/

PyFlink is compatible with Python>=3.5<3.9

Process:

1. Produce events and send to Kafka topic
2. Set up streaming service via PyFlink DataStream API
3. Read from Kafka source via PyFlink TABLE API
4. Process data

AniketSaki

Keybase proof

I hereby claim:

• I am aniketsaki on github.
• I am sakihenry (https://keybase.io/sakihenry) on keybase.
• I have a public key ASAIiuvRSdnaAuBhAT45--wspH2Ts5u_MCSDMPcaaWkctwo

To claim this, I am signing this object: