René's URL Explorer Experiment


Title: Kafka Loader by incrypto32 · Pull Request #11 · edgeandnode/amp-python · GitHub

Open Graph Title: Kafka Loader by incrypto32 · Pull Request #11 · edgeandnode/amp-python

X Title: Kafka Loader by incrypto32 · Pull Request #11 · edgeandnode/amp-python

Opengraph URL: https://github.com/edgeandnode/amp-python/pull/11

X: @github

direct link

Domain: patch-diff.githubusercontent.com

route-pattern/_view_fragments/voltron/pull_requests/show/:user_id/:repository/:id/pull_request_layout(.:format)
route-controllervoltron_pull_requests_fragments
route-actionpull_request_layout
fetch-noncev2:5bfcc7f6-a8b1-d938-6bdd-f4aeaed65f96
current-catalog-service-hashae870bc5e265a340912cde392f23dad3671a0a881730ffdadd82f2f57d81641b
request-idA534:3316F:5A628D:7CBE3E:69737C4A
html-safe-nonced220306f25a54613c707eac522c50b60243f4c8e6ef3877e02b20140b8849b6b
visitor-payloadeyJyZWZlcnJlciI6IiIsInJlcXVlc3RfaWQiOiJBNTM0OjMzMTZGOjVBNjI4RDo3Q0JFM0U6Njk3MzdDNEEiLCJ2aXNpdG9yX2lkIjoiMzY4OTEwNzIxMDg1Njc5MTExNCIsInJlZ2lvbl9lZGdlIjoiaWFkIiwicmVnaW9uX3JlbmRlciI6ImlhZCJ9
visitor-hmac6d2edf70e0423a9468768a79f6434bc4a4f85722b418c024240d43b56f4dede1
hovercard-subject-tagpull_request:2932499492
github-keyboard-shortcutsrepository,pull-request-list,pull-request-conversation,pull-request-files-changed,copilot
google-site-verificationApib7-x98H0j5cPqHWwSMm6dNU4GmODRoqxLiDzdx9I
octolytics-urlhttps://collector.github.com/github/collect
analytics-location///voltron/pull_requests_fragments/pull_request_layout
fb:app_id1401488693436528
apple-itunes-appapp-id=1477376905, app-argument=https://github.com/_view_fragments/voltron/pull_requests/show/edgeandnode/amp-python/11/pull_request_layout
twitter:imagehttps://opengraph.githubassets.com/a5b4cbb2f7c3ee45980854d9a0544cd4f786ee8ee3d548ddf8b47fd5f8e45eb0/edgeandnode/amp-python/pull/11
twitter:cardsummary_large_image
og:imagehttps://opengraph.githubassets.com/a5b4cbb2f7c3ee45980854d9a0544cd4f786ee8ee3d548ddf8b47fd5f8e45eb0/edgeandnode/amp-python/pull/11
og:image:width1200
og:image:height600
og:site_nameGitHub
og:typeobject
og:author:usernameincrypto32
hostnamegithub.com
expected-hostnamegithub.com
None4cf879a11b0a28a85543899a36aaee9ec9ca2fb7bedad86c0da5731193c95f01
turbo-cache-controlno-preview
go-importgithub.com/edgeandnode/amp-python git https://github.com/edgeandnode/amp-python.git
octolytics-dimension-user_id75350555
octolytics-dimension-user_loginedgeandnode
octolytics-dimension-repository_id1054462835
octolytics-dimension-repository_nwoedgeandnode/amp-python
octolytics-dimension-repository_publictrue
octolytics-dimension-repository_is_forkfalse
octolytics-dimension-repository_network_root_id1054462835
octolytics-dimension-repository_network_root_nwoedgeandnode/amp-python
turbo-body-classeslogged-out env-production page-responsive
disable-turbofalse
browser-stats-urlhttps://api.github.com/_private/browser/stats
browser-errors-urlhttps://api.github.com/_private/browser/errors
releasefe8be790582ef7a55477ce1918ac0ed16b106d31
ui-targetcanary-2
theme-color#1e2327
color-schemelight dark

Links:

Skip to contenthttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#start-of-content
https://patch-diff.githubusercontent.com/
Sign in https://patch-diff.githubusercontent.com/login?return_to=https%3A%2F%2Fgithub.com%2Fedgeandnode%2Famp-python%2Fpull%2F11
GitHub CopilotWrite better code with AIhttps://github.com/features/copilot
GitHub SparkBuild and deploy intelligent appshttps://github.com/features/spark
GitHub ModelsManage and compare promptshttps://github.com/features/models
MCP RegistryNewIntegrate external toolshttps://github.com/mcp
ActionsAutomate any workflowhttps://github.com/features/actions
CodespacesInstant dev environmentshttps://github.com/features/codespaces
IssuesPlan and track workhttps://github.com/features/issues
Code ReviewManage code changeshttps://github.com/features/code-review
GitHub Advanced SecurityFind and fix vulnerabilitieshttps://github.com/security/advanced-security
Code securitySecure your code as you buildhttps://github.com/security/advanced-security/code-security
Secret protectionStop leaks before they starthttps://github.com/security/advanced-security/secret-protection
Why GitHubhttps://github.com/why-github
Documentationhttps://docs.github.com
Bloghttps://github.blog
Changeloghttps://github.blog/changelog
Marketplacehttps://github.com/marketplace
View all featureshttps://github.com/features
Enterpriseshttps://github.com/enterprise
Small and medium teamshttps://github.com/team
Startupshttps://github.com/enterprise/startups
Nonprofitshttps://github.com/solutions/industry/nonprofits
App Modernizationhttps://github.com/solutions/use-case/app-modernization
DevSecOpshttps://github.com/solutions/use-case/devsecops
DevOpshttps://github.com/solutions/use-case/devops
CI/CDhttps://github.com/solutions/use-case/ci-cd
View all use caseshttps://github.com/solutions/use-case
Healthcarehttps://github.com/solutions/industry/healthcare
Financial serviceshttps://github.com/solutions/industry/financial-services
Manufacturinghttps://github.com/solutions/industry/manufacturing
Governmenthttps://github.com/solutions/industry/government
View all industrieshttps://github.com/solutions/industry
View all solutionshttps://github.com/solutions
AIhttps://github.com/resources/articles?topic=ai
Software Developmenthttps://github.com/resources/articles?topic=software-development
DevOpshttps://github.com/resources/articles?topic=devops
Securityhttps://github.com/resources/articles?topic=security
View all topicshttps://github.com/resources/articles
Customer storieshttps://github.com/customer-stories
Events & webinarshttps://github.com/resources/events
Ebooks & reportshttps://github.com/resources/whitepapers
Business insightshttps://github.com/solutions/executive-insights
GitHub Skillshttps://skills.github.com
Documentationhttps://docs.github.com
Customer supporthttps://support.github.com
Community forumhttps://github.com/orgs/community/discussions
Trust centerhttps://github.com/trust-center
Partnershttps://github.com/partners
GitHub SponsorsFund open source developershttps://github.com/sponsors
Security Labhttps://securitylab.github.com
Maintainer Communityhttps://maintainers.github.com
Acceleratorhttps://github.com/accelerator
Archive Programhttps://archiveprogram.github.com
Topicshttps://github.com/topics
Trendinghttps://github.com/trending
Collectionshttps://github.com/collections
Enterprise platformAI-powered developer platformhttps://github.com/enterprise
GitHub Advanced SecurityEnterprise-grade security featureshttps://github.com/security/advanced-security
Copilot for BusinessEnterprise-grade AI featureshttps://github.com/features/copilot/copilot-business
Premium SupportEnterprise-grade 24/7 supporthttps://github.com/premium-support
Pricinghttps://github.com/pricing
Search syntax tipshttps://docs.github.com/search-github/github-code-search/understanding-github-code-search-syntax
documentationhttps://docs.github.com/search-github/github-code-search/understanding-github-code-search-syntax
Sign in https://patch-diff.githubusercontent.com/login?return_to=https%3A%2F%2Fgithub.com%2Fedgeandnode%2Famp-python%2Fpull%2F11
Sign up https://patch-diff.githubusercontent.com/signup?ref_cta=Sign+up&ref_loc=header+logged+out&ref_page=%2F%3Cuser-name%3E%2F%3Crepo-name%3E%2Fvoltron%2Fpull_requests_fragments%2Fpull_request_layout&source=header-repo&source_repo=edgeandnode%2Famp-python
Reloadhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11
Reloadhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11
Reloadhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11
edgeandnode https://patch-diff.githubusercontent.com/edgeandnode
amp-pythonhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python
Notifications https://patch-diff.githubusercontent.com/login?return_to=%2Fedgeandnode%2Famp-python
Fork 1 https://patch-diff.githubusercontent.com/login?return_to=%2Fedgeandnode%2Famp-python
Star 2 https://patch-diff.githubusercontent.com/login?return_to=%2Fedgeandnode%2Famp-python
Code https://patch-diff.githubusercontent.com/edgeandnode/amp-python
Issues 6 https://patch-diff.githubusercontent.com/edgeandnode/amp-python/issues
Pull requests 10 https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pulls
Actions https://patch-diff.githubusercontent.com/edgeandnode/amp-python/actions
Projects 0 https://patch-diff.githubusercontent.com/edgeandnode/amp-python/projects
Security 0 https://patch-diff.githubusercontent.com/edgeandnode/amp-python/security
Insights https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pulse
Code https://patch-diff.githubusercontent.com/edgeandnode/amp-python
Issues https://patch-diff.githubusercontent.com/edgeandnode/amp-python/issues
Pull requests https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pulls
Actions https://patch-diff.githubusercontent.com/edgeandnode/amp-python/actions
Projects https://patch-diff.githubusercontent.com/edgeandnode/amp-python/projects
Security https://patch-diff.githubusercontent.com/edgeandnode/amp-python/security
Insights https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pulse
Sign up for GitHub https://patch-diff.githubusercontent.com/signup?return_to=%2Fedgeandnode%2Famp-python%2Fissues%2Fnew%2Fchoose
terms of servicehttps://docs.github.com/terms
privacy statementhttps://docs.github.com/privacy
Sign inhttps://patch-diff.githubusercontent.com/login?return_to=%2Fedgeandnode%2Famp-python%2Fissues%2Fnew%2Fchoose
Jump to bottomhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#issue-comment-box
incrypto32https://patch-diff.githubusercontent.com/incrypto32
mainhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/tree/main
krishna/kafkahttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/tree/krishna/kafka
Kafka Loader https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#top
incrypto32https://patch-diff.githubusercontent.com/incrypto32
mainhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/tree/main
krishna/kafkahttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/tree/krishna/kafka
Conversation 2 https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11
Commits 26 https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits
Checks 9 https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/checks
Files changed https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/files
Please reload this pagehttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11
https://github.co/hiddenchars
https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/{{ revealButtonHref }}
https://patch-diff.githubusercontent.com/incrypto32
incrypto32https://patch-diff.githubusercontent.com/incrypto32
Oct 21, 2025https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#issue-3535542764
Please reload this pagehttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11
https://patch-diff.githubusercontent.com/incrypto32
incrypto32https://patch-diff.githubusercontent.com/incrypto32
October 21, 2025 08:41https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-20398750625
https://patch-diff.githubusercontent.com/fordN
fordNhttps://patch-diff.githubusercontent.com/fordN
force-pushedhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/3f2b9051ebc946005f5c3f6dcbfd44ce28c8d1ac..f93a7e6a375e19b09b66ce9edde7010d69b29760
3f2b905https://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/3f2b9051ebc946005f5c3f6dcbfd44ce28c8d1ac
f93a7e6https://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/f93a7e6a375e19b09b66ce9edde7010d69b29760
Compare https://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/3f2b9051ebc946005f5c3f6dcbfd44ce28c8d1ac..f93a7e6a375e19b09b66ce9edde7010d69b29760
October 22, 2025 15:21https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-20433989623
October 22, 2025 17:30https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-20436415770
https://patch-diff.githubusercontent.com/incrypto32
incrypto32https://patch-diff.githubusercontent.com/incrypto32
October 27, 2025 14:49https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-20527789957
https://patch-diff.githubusercontent.com/incrypto32
incrypto32https://patch-diff.githubusercontent.com/incrypto32
force-pushedhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/48a755bbefe11ce76e72b8465c8715d66974d437..aa0c95876eb4c58a3a9cabadd00721b045edc205
48a755bhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/48a755bbefe11ce76e72b8465c8715d66974d437
aa0c958https://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/aa0c95876eb4c58a3a9cabadd00721b045edc205
Compare https://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/48a755bbefe11ce76e72b8465c8715d66974d437..aa0c95876eb4c58a3a9cabadd00721b045edc205
October 27, 2025 14:57https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-20528023446
https://patch-diff.githubusercontent.com/incrypto32
incrypto32https://patch-diff.githubusercontent.com/incrypto32
force-pushedhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/aa0c95876eb4c58a3a9cabadd00721b045edc205..b27fa32bca4d2df50ee95f58e83ddd21db63a74b
aa0c958https://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/aa0c95876eb4c58a3a9cabadd00721b045edc205
b27fa32https://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/b27fa32bca4d2df50ee95f58e83ddd21db63a74b
Compare https://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/aa0c95876eb4c58a3a9cabadd00721b045edc205..b27fa32bca4d2df50ee95f58e83ddd21db63a74b
November 16, 2025 16:36https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-20972765709
https://patch-diff.githubusercontent.com/incrypto32
incrypto32https://patch-diff.githubusercontent.com/incrypto32
November 16, 2025 16:37https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-20972771041
https://patch-diff.githubusercontent.com/incrypto32
incrypto32https://patch-diff.githubusercontent.com/incrypto32
force-pushedhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/ad48f0e4aa6eb0fbefa7a43c135dae3efb818826..1a2c152d3c884c661ea03e3f004c79541a99cf93
ad48f0ehttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/ad48f0e4aa6eb0fbefa7a43c135dae3efb818826
1a2c152https://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/1a2c152d3c884c661ea03e3f004c79541a99cf93
Compare https://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/ad48f0e4aa6eb0fbefa7a43c135dae3efb818826..1a2c152d3c884c661ea03e3f004c79541a99cf93
November 17, 2025 08:01https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-20980495035
https://patch-diff.githubusercontent.com/incrypto32
incrypto32https://patch-diff.githubusercontent.com/incrypto32
force-pushedhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/7240b7b33d22d158e5cd9efbd6e742789a20a234..c71da182129f3588eb81c70033902e63a810e3c4
7240b7bhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/7240b7b33d22d158e5cd9efbd6e742789a20a234
c71da18https://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/c71da182129f3588eb81c70033902e63a810e3c4
Compare https://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/7240b7b33d22d158e5cd9efbd6e742789a20a234..c71da182129f3588eb81c70033902e63a810e3c4
November 25, 2025 11:13https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-21162045421
https://patch-diff.githubusercontent.com/edgeandnode
edgeandnodehttps://patch-diff.githubusercontent.com/edgeandnode
github-actionshttps://patch-diff.githubusercontent.com/apps/github-actions
Nov 25, 2025https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-21162393471
https://patch-diff.githubusercontent.com/craigtutterow
craigtutterowhttps://patch-diff.githubusercontent.com/craigtutterow
Dec 2, 2025 https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#pullrequestreview-3531294808
View reviewed changes https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/files
craigtutterowhttps://patch-diff.githubusercontent.com/craigtutterow
Please reload this pagehttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11
https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#pullrequestreview-3531294808
Learn morehttps://docs.github.com/articles/managing-disruptive-comments/#hiding-a-comment
Please reload this pagehttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11
https://patch-diff.githubusercontent.com/incrypto32
incrypto32https://patch-diff.githubusercontent.com/incrypto32
Dec 2, 2025https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#issuecomment-3603159583
@craigtutterowhttps://github.com/craigtutterow
Please reload this pagehttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11
https://patch-diff.githubusercontent.com/incrypto32
incrypto32https://patch-diff.githubusercontent.com/incrypto32
force-pushedhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/a34d49d0b8fa44d9494178014a5a4a2b68e1e5a1..9013dc48766099ead405977e84aec616e57713a5
a34d49dhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/a34d49d0b8fa44d9494178014a5a4a2b68e1e5a1
9013dc4https://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/9013dc48766099ead405977e84aec616e57713a5
Compare https://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/a34d49d0b8fa44d9494178014a5a4a2b68e1e5a1..9013dc48766099ead405977e84aec616e57713a5
December 15, 2025 17:26https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-21572544417
https://patch-diff.githubusercontent.com/incrypto32
incrypto32https://patch-diff.githubusercontent.com/incrypto32
force-pushedhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/075c0170212049c665ff0aa281df08e2a270378c..d3d8ddade06996b58153eb79475a2bf5df6cba42
075c017https://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/075c0170212049c665ff0aa281df08e2a270378c
d3d8ddahttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/d3d8ddade06996b58153eb79475a2bf5df6cba42
Compare https://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/075c0170212049c665ff0aa281df08e2a270378c..d3d8ddade06996b58153eb79475a2bf5df6cba42
January 9, 2026 10:21https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-21944123040
incrypto32https://patch-diff.githubusercontent.com/incrypto32
January 11, 2026 17:09https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#commits-pushed-0ad1c4b
https://patch-diff.githubusercontent.com/incrypto32
Remove incorrect duplicate batch skipping in ReorgAwareStreamhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/0ad1c4b58bcb123b1483aa18d4b75bd1a7f8932e
0ad1c4bhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/0ad1c4b58bcb123b1483aa18d4b75bd1a7f8932e
https://patch-diff.githubusercontent.com/incrypto32
Implement a LMDB stream state storehttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/65a73f5c73c41d7818aa434b527d44bd09f1af7e
65a73f5https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/65a73f5c73c41d7818aa434b527d44bd09f1af7e
https://patch-diff.githubusercontent.com/incrypto32
incrypto32https://patch-diff.githubusercontent.com/incrypto32
force-pushedhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/d3d8ddade06996b58153eb79475a2bf5df6cba42..2ebf6ec08160b0359511c832f8fb5c5747a55192
d3d8ddahttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/d3d8ddade06996b58153eb79475a2bf5df6cba42
2ebf6echttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/2ebf6ec08160b0359511c832f8fb5c5747a55192
Compare https://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/d3d8ddade06996b58153eb79475a2bf5df6cba42..2ebf6ec08160b0359511c832f8fb5c5747a55192
January 11, 2026 13:19https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-21970313064
incrypto32https://patch-diff.githubusercontent.com/incrypto32
January 11, 2026 19:07https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#commits-pushed-ef69741
https://patch-diff.githubusercontent.com/incrypto32
Add configurable data_dir for LMDB state storagehttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/ef697413d40c0696f924f390035375c72e76d864
ef69741https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/ef697413d40c0696f924f390035375c72e76d864
https://patch-diff.githubusercontent.com/incrypto32
implement a Kafka loaderhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/9f948c504f480f0f5f4779d54035b70e5b26771e
9f948c5https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/9f948c504f480f0f5f4779d54035b70e5b26771e
https://patch-diff.githubusercontent.com/incrypto32
Add kafka streaming loader apphttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/7af461adfb3e3c983516e04e3f8985322037a709
7af461ahttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/7af461adfb3e3c983516e04e3f8985322037a709
https://patch-diff.githubusercontent.com/incrypto32
Refactor kafka streaming loader and fix Resume watermarkhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/3669668fdd61343bf4b84837d2070852cd872d6e
3669668https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/3669668fdd61343bf4b84837d2070852cd872d6e
https://patch-diff.githubusercontent.com/incrypto32
use transactions in kafka loaderhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/32a39871e1c026140073b615ab771bf08c33cff1
32a3987https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/32a39871e1c026140073b615ab771bf08c33cff1
https://patch-diff.githubusercontent.com/incrypto32
Fix unit tests failinghttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/fba0bd2cb35765689a05602e268849b95a1fac91
fba0bd2https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/fba0bd2cb35765689a05602e268849b95a1fac91
incrypto32https://patch-diff.githubusercontent.com/incrypto32
January 11, 2026 19:08https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#commits-pushed-1c18cad
https://patch-diff.githubusercontent.com/incrypto32
Add more integration tests for kafka loaderhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/1c18cadd583acae6323eb51f1702a50174d6f10c
1c18cadhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/1c18cadd583acae6323eb51f1702a50174d6f10c
https://patch-diff.githubusercontent.com/incrypto32
Add a simple kafka consumer scripthttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/abb28c21f2d290b9a036d4bb1d05bc28b2cd9dae
abb28c2https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/abb28c21f2d290b9a036d4bb1d05bc28b2cd9dae
https://patch-diff.githubusercontent.com/incrypto32
Dockerize kafka loaderhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/be86d5aa38b878f72602a02a6b7c37f0e7a8e8fc
be86d5ahttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/be86d5aa38b878f72602a02a6b7c37f0e7a8e8fc
https://patch-diff.githubusercontent.com/incrypto32
use lmdb stream state for kafka loaderhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/2fbe91a85fb2bd97c40e3aafc4d147cbfb57fca1
2fbe91ahttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/2fbe91a85fb2bd97c40e3aafc4d147cbfb57fca1
https://patch-diff.githubusercontent.com/incrypto32
Docs for kafka loaderhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/5beea22efa1cb48d6502aca3c8f253946c789b36
5beea22https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/5beea22efa1cb48d6502aca3c8f253946c789b36
https://patch-diff.githubusercontent.com/incrypto32
Add example query with specific schemahttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/648a1c8f74b3df44276d1e928ea25929b004e4bc
648a1c8https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/648a1c8f74b3df44276d1e928ea25929b004e4bc
https://patch-diff.githubusercontent.com/incrypto32
Udpate docs for kafka loader and fix queryhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/6c8e2376d01419323552d3e02638cc643fd74097
6c8e237https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/6c8e2376d01419323552d3e02638cc643fd74097
https://patch-diff.githubusercontent.com/incrypto32
Fix integration test failureshttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/53e11a7bbd61852d31b35233061556e81be4ca4e
53e11a7https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/53e11a7bbd61852d31b35233061556e81be4ca4e
https://patch-diff.githubusercontent.com/incrypto32
Quote dataset names in SQL queries to support slasheshttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/7e85d29c3e7186baa32242cfad3dd0d7def5c54e
7e85d29https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/7e85d29c3e7186baa32242cfad3dd0d7def5c54e
https://patch-diff.githubusercontent.com/incrypto32
Pass data_dir config to LMDB state store in Kafka loaderhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/4970fcf0f6211b946eff3f8c94c24829d0e453a5
4970fcfhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/4970fcf0f6211b946eff3f8c94c24829d0e453a5
https://patch-diff.githubusercontent.com/incrypto32
Add --state-dir CLI parameter for LMDB state storage pathhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/1c79ead61b5048df50265372afb4585722eba16e
1c79eadhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/1c79ead61b5048df50265372afb4585722eba16e
https://patch-diff.githubusercontent.com/incrypto32
incrypto32https://patch-diff.githubusercontent.com/incrypto32
force-pushedhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/dfc08ed2924bec3fc42d0a601dbf2885f8cd054f..deaa9d17c739c9acdbceb4a9c061e9f255ad847d
dfc08edhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/dfc08ed2924bec3fc42d0a601dbf2885f8cd054f
deaa9d1https://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/deaa9d17c739c9acdbceb4a9c061e9f255ad847d
Compare https://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/dfc08ed2924bec3fc42d0a601dbf2885f8cd054f..deaa9d17c739c9acdbceb4a9c061e9f255ad847d
January 12, 2026 14:01https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-21990409857
https://patch-diff.githubusercontent.com/edgeandnode
edgeandnodehttps://patch-diff.githubusercontent.com/edgeandnode
github-actionshttps://patch-diff.githubusercontent.com/apps/github-actions
Jan 12, 2026https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-21990413158
https://patch-diff.githubusercontent.com/incrypto32
Add auth, retry logic, and proper logging to Kafka streaming loaderhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/ffa520ede4d819d4f06dbd4881cddf77c1e2eb71
ffa520ehttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/ffa520ede4d819d4f06dbd4881cddf77c1e2eb71
https://patch-diff.githubusercontent.com/incrypto32
incrypto32https://patch-diff.githubusercontent.com/incrypto32
force-pushedhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/deaa9d17c739c9acdbceb4a9c061e9f255ad847d..ffa520ede4d819d4f06dbd4881cddf77c1e2eb71
deaa9d1https://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/deaa9d17c739c9acdbceb4a9c061e9f255ad847d
ffa520ehttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/ffa520ede4d819d4f06dbd4881cddf77c1e2eb71
Compare https://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/deaa9d17c739c9acdbceb4a9c061e9f255ad847d..ffa520ede4d819d4f06dbd4881cddf77c1e2eb71
January 12, 2026 15:12https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-21992221387
https://patch-diff.githubusercontent.com/edgeandnode
edgeandnodehttps://patch-diff.githubusercontent.com/edgeandnode
github-actionshttps://patch-diff.githubusercontent.com/apps/github-actions
Jan 12, 2026https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-21992231050
incrypto32https://patch-diff.githubusercontent.com/incrypto32
January 13, 2026 13:03https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#commits-pushed-91a1a66
https://patch-diff.githubusercontent.com/incrypto32
Add pass-through Kafka producer config via --kafka-confighttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/91a1a661f37fb75f6e5bc2e3976c2870affa7701
91a1a66https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/91a1a661f37fb75f6e5bc2e3976c2870affa7701
https://patch-diff.githubusercontent.com/incrypto32
Add last_valid_hash to reorg messageshttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/d32373bdb7582e7a32483a9b2817a85a874158d6
d32373bhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/d32373bdb7582e7a32483a9b2817a85a874158d6
https://patch-diff.githubusercontent.com/incrypto32
Add block range to batch log outputhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/3b16f82cd2f57ecebb628e4115e4391c3aad895a
3b16f82https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/3b16f82cd2f57ecebb628e4115e4391c3aad895a
https://patch-diff.githubusercontent.com/incrypto32
incrypto32https://patch-diff.githubusercontent.com/incrypto32
force-pushedhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/1b081d693983bba03e5c3106bd5d0130b931973e..3b16f82cd2f57ecebb628e4115e4391c3aad895a
1b081d6https://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/1b081d693983bba03e5c3106bd5d0130b931973e
3b16f82https://patch-diff.githubusercontent.com/edgeandnode/amp-python/commit/3b16f82cd2f57ecebb628e4115e4391c3aad895a
Compare https://patch-diff.githubusercontent.com/edgeandnode/amp-python/compare/1b081d693983bba03e5c3106bd5d0130b931973e..3b16f82cd2f57ecebb628e4115e4391c3aad895a
January 13, 2026 15:58https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-22020940239
https://patch-diff.githubusercontent.com/edgeandnode
edgeandnodehttps://patch-diff.githubusercontent.com/edgeandnode
github-actionshttps://patch-diff.githubusercontent.com/apps/github-actions
Jan 14, 2026https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#event-22034936434
incrypto32https://patch-diff.githubusercontent.com/incrypto32
January 14, 2026 11:48https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11#commits-pushed-c770308
https://patch-diff.githubusercontent.com/incrypto32
Add --reorg-topic option for separate reorg message topichttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/c7703087dad7a46c86d1eab5b915a9965663cbef
c770308https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/c7703087dad7a46c86d1eab5b915a9965663cbef
https://patch-diff.githubusercontent.com/incrypto32
Support --start-block=latest to start from current chain tiphttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/cefd9ef85639ad2e8bf5bcf85d4705d86bf1ff92
cefd9efhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/cefd9ef85639ad2e8bf5bcf85d4705d86bf1ff92
https://patch-diff.githubusercontent.com/incrypto32
Update Kafka loader guide with new options and Docker examplehttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/b07241f4480fab38a6bfb0de2337a0e325a6b671
b07241fhttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/commits/b07241f4480fab38a6bfb0de2337a0e325a6b671
Sign up for freehttps://patch-diff.githubusercontent.com/join?source=comment-repo
Sign in to commenthttps://patch-diff.githubusercontent.com/login?return_to=https%3A%2F%2Fgithub.com%2Fedgeandnode%2Famp-python%2Fpull%2F11
https://patch-diff.githubusercontent.com/craigtutterow
craigtutterow https://patch-diff.githubusercontent.com/craigtutterow
https://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11/files/a8a18d498973a518f38235c978c60f85701d904e
Please reload this pagehttps://patch-diff.githubusercontent.com/edgeandnode/amp-python/pull/11
https://patch-diff.githubusercontent.com/incrypto32
https://patch-diff.githubusercontent.com/craigtutterow
https://patch-diff.githubusercontent.com/apps/copilot-swe-agent
https://github.com
Termshttps://docs.github.com/site-policy/github-terms/github-terms-of-service
Privacyhttps://docs.github.com/site-policy/privacy-policies/github-privacy-statement
Securityhttps://github.com/security
Statushttps://www.githubstatus.com/
Communityhttps://github.community/
Docshttps://docs.github.com/
Contacthttps://support.github.com?tags=dotcom-footer

Viewport: width=device-width

URLs of crawlers that visited me.