Skip to content

Kafka Loader #11

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom
Draft
incrypto32 wants to merge 16 commits into
base: main
Choose a base branch
from
Draft

Kafka Loader #11

incrypto32 wants to merge 16 commits into from

Conversation

@incrypto32
Copy link
Member

@incrypto32 incrypto32 commented Oct 21, 2025

No description provided.

@incrypto32 incrypto32 changed the base branch from main to ford/streaming October 21, 2025 08:41
Base automatically changed from ford/streaming to main October 22, 2025 17:30
@incrypto32 incrypto32 changed the base branch from main to ford/stream-hardening October 27, 2025 14:49
@incrypto32 incrypto32 changed the base branch from ford/stream-hardening to main November 16, 2025 16:37
@incrypto32 incrypto32 force-pushed the krishna/kafka branch 3 times, most recently from ad48f0e to 1a2c152 Compare November 17, 2025 08:01
@incrypto32 incrypto32 force-pushed the krishna/kafka branch 5 times, most recently from 06e48af to 7240b7b Compare November 25, 2025 11:10
@edgeandnode edgeandnode deleted a comment from github-actions bot Nov 25, 2025
craigtutterow
craigtutterow reviewed Dec 2, 2025
View reviewed changes
Copy link

@craigtutterow craigtutterow left a comment •
edited
Loading

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Could you also include an example loader implementation that produces json data in the schema needed by DTCC?

Example record:

version: 1.0
chain: 1234
block_num: 20833796
block_hash: 0x3f72b1c462ecdcec423255f1d341d8789c39be0916f8adfd4b3f9c6290a4a22c
transaction: 0x96db8730969fcfa12084b840fc2ac6bf14ba15d8b5762e44f82d4b3648a447cf
activity_identity: wallet
activity_type: payment
activity_address: 0xBF19CbF0256f19f39A016a86Ff3551ecC6f2aAFE
activity_operations: [[id: "log:208:1", token: 0x808507121B80c02388fAd14726482e061B8da827, address: 0xBF19CbF0256f19f39A016a86Ff3551ecC6f2aAFE, amount: -92.597518289673167661, type: debited],[id: "", token: 0x808507121B80c02388fAd14726482e061B8da827, address: 0x1111111254EEB25477B68fb85Ed929f73A960582, amount: -92.597518289673167661, type: credited]]
token_address: 0x808507121B80c02388fAd14726482e061B8da827
token_symbol: PENDLE
token_name: Pendle
token_decimals: 18`

@incrypto32
Copy link
Member Author

incrypto32 commented Dec 2, 2025

@craigtutterow sure, i'll udpate and add an example

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

@craigtutterow craigtutterow craigtutterow left review comments

At least 1 approving review is required to merge this pull request.

Assignees

No one assigned

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

3 participants

@incrypto32 @craigtutterow