Skip to content

Navigation Menu

Appearance settings

View all features
- BY COMPANY SIZE
  Enterprises
  Small and medium teams
  Startups
  Nonprofits
- BY USE CASE
  App Modernization
  DevSecOps
  DevOps
  CI/CD
  View all use cases
- BY INDUSTRY
  Healthcare
  Financial services
  Manufacturing
  Government
  View all industries
View all solutions
- EXPLORE BY TOPIC
  AI
  Software Development
  DevOps
  Security
  View all topics
- EXPLORE BY TYPE
  Customer stories
  Events & webinars
  Ebooks & reports
  Business insights
  GitHub Skills
- SUPPORT & SERVICES
  Documentation
  Customer support
  Community forum
  Trust center
  Partners
View all resources
- COMMUNITY
  GitHub SponsorsFund open source developers
- PROGRAMS
  Security Lab
  Maintainer Community
  Accelerator
  GitHub Stars
  Archive Program
- REPOSITORIES
  Topics
  Trending
  Collections
- ENTERPRISE SOLUTIONS
  Enterprise platformAI-powered developer platform
- AVAILABLE ADD-ONS
  GitHub Advanced SecurityEnterprise-grade security features
  Copilot for BusinessEnterprise-grade AI features
  Premium SupportEnterprise-grade 24/7 support
Pricing

Search code, repositories, users, issues, pull requests...

Search

Clear

Search syntax tips

Provide feedback

We read every piece of feedback, and take your input very seriously.

Include my email address so I can be contacted

Saved searches

Use saved searches to filter your results more quickly

Name

Query

To see all available qualifiers, see our documentation.

Appearance settings

You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session. You switched accounts on another tab or window. Reload to refresh your session.

Dismiss alert

apache / iggy Public

Notifications You must be signed in to change notification settings
Fork 305
Star 4.2k

Code
Issues 81
Pull requests 32
Discussions
Actions
Projects
Security and quality
Insights

Additional navigation options

Code
Issues
Pull requests
Discussions
Actions
Projects
Security and quality
Insights

feat(connectors): add generic HTTP sink connector#2925

Merged

hubcio merged 50 commits intoapache:masterapache/iggy:masterfrom

mlevkov:feat/http-sink-connectormlevkov/iggy:feat/http-sink-connectorCopy head branch name to clipboard

Apr 1, 2026

Conversation Commits50 (50)Checks Files changed

Merged

feat(connectors): add generic HTTP sink connector#2925
hubcio merged 50 commits intoapache:masterfrom
mlevkov:feat/http-sink-connector

Commits

Commits on Apr 1, 2026

feat(connectors): scaffold HTTP sink connector with types and stub Sink impl

mlevkov
and
claude
committed
feat(connectors): implement HTTP sink core — consume, retry, batch modes

mlevkov
and
claude
committed
fix(connectors): remediate 12 review findings in HTTP sink (CR round 1)

mlevkov
and
claude
committed
fix(connectors): remediate 7 follow-up review findings in HTTP sink (CR round 2)

mlevkov
and
claude
committed
docs(connectors): add HTTP sink example config.toml

mlevkov
and
claude
committed
docs(connectors): add HTTP sink README with usage, config reference, known limitations

mlevkov
and
claude
committed
test(connectors): add 46 unit tests for HTTP sink connector

mlevkov
and
claude
committed
fix(connectors): address 5 test/docs review findings for HTTP sink

mlevkov
and
claude
committed
test(connectors): add integration tests for HTTP sink using WireMock

mlevkov
and
claude
committed
fix(connectors): remediate round 1 review findings for HTTP sink

mlevkov
and
claude
committed
fix(connectors): remediate round 2 review findings for HTTP sink

mlevkov
and
claude
committed
docs(connectors): expand HTTP sink README with use cases, auth, deployment patterns

mlevkov
and
claude
committed
feat(http-sink): add TCP keep-alive and connection pool idle timeout

mlevkov
and
claude
committed
test(http-sink): add multi-topic integration test

mlevkov
and
claude
committed
docs(http-sink): add connector runtime model and achievability table

mlevkov
and
claude
committed
docs(http-sink): add runtime source references and connection pool details

mlevkov
and
claude
committed
docs(http-sink): add message flow section explaining input vs output structure

mlevkov
and
claude
committed
fix(http-sink): remediate code review findings — error accounting, validation, docs

mlevkov
and
claude
committed
refactor(http-sink): use Bytes type in send_batch_body signature for clarity

mlevkov
and
claude
committed
fix(http-sink): remediate follow-up review findings (F1-F6)

mlevkov
and
claude
committed
docs(http-sink): add comprehensive integration test documentation

mlevkov
and
claude
committed
fix(http-sink): fix compilation errors and apply rustfmt formatting

mlevkov
and
claude
committed
style(http-sink): align ASCII architecture diagram in test docs

mlevkov
and
claude
committed
fix(http-sink): resolve 5 CI failures — typos, markdown, fmt, licenses, multi-topic test

mlevkov
and
claude
committed
refactor(sdk): move owned_value_to_serde_json to iggy_connector_sdk::convert
mlevkov
committed
refactor(http-sink): address PR #2925 review — items #1-11

mlevkov
and
claude
committed
chore(http-sink): test doc trimming, config cleanup — items #8, #12-14

mlevkov
and
claude
committed
fix(http-sink): remediate CR round 1 — 8 findings across 6 agents

mlevkov
and
claude
committed
style(http-sink): apply cargo fmt formatting

mlevkov
and
claude
committed
chore: regenerate lockfile, fix markdown lint errors

mlevkov
and
claude
committed
refactor(elasticsearch-sink): use shared owned_value_to_serde_json from SDK

mlevkov
and
claude
committed
fix(http-sink): update imports after upstream binary_protocol refactor

mlevkov
and
claude
committed
refactor: rename BatchMode::Ndjson to NdJson for consistent casing

mlevkov
and
claude
committed
refactor: add field name constants, replace inline string literals

mlevkov
and
claude
committed
refactor: derive strum Display on BatchMode, remove mode_name params

mlevkov
and
claude
committed
refactor: move content_type() from HttpSink to BatchMode impl

mlevkov
and
claude
committed
refactor: replace json! macros with strongly typed structs

mlevkov
and
claude
committed
refactor: use FIELD_* constants in test assertions

mlevkov
and
claude
committed
refactor: remove comment separators, reorder helpers below tests

mlevkov
and
claude
committed
refactor: remove client parameter threading from send methods

mlevkov
and
claude
committed
refactor: replace UUID v8 format with simple 32-char hex

mlevkov
and
claude
committed
refactor: replace hand-rolled retry with reqwest-middleware

mlevkov
and
claude
committed
fix: remediate CR Round 1 findings (2 CRITICAL, 4 HIGH)

mlevkov
and
claude
committed
docs: update README and config for refactored HTTP sink

mlevkov
and
claude
committed
chore: update Cargo.lock after rebase on master

mlevkov
and
claude
committed
chore: remove unused FIELD_HEADER_ENCODING test constant

mlevkov
and
claude
committed
fix: serialize NdJson as "ndjson" (industry standard per ndjson.org)

mlevkov
and
claude
committed
refactor: address hubcio review — URL sanitization, NDJSON alloc, serialization

mlevkov
and
claude
committed
fix: remediate review findings — collapse envelope methods, harden URL sanitization

mlevkov
and
claude
committed
Merge branch 'master' into feat/http-sink-connector
spetz
authored

Footer

© 2026 GitHub, Inc.

Footer navigation

Terms
Privacy
Security
Status
Community
Docs
Contact

You can’t perform that action at this time.