apache/iggy

View on GitHub

Apache Iggy: Hyper-Efficient Message Streaming at Laser Speed

Stars: 4.9k
Forks: 432
Open beginner issues: 0
Indexed issues: 156
Avg merge: 2d 10h
Merged PRs (30d): 174

Dominant language: Rust
License: Apache-2.0
Last GitHub push: Sep 14, 2026
Latest indexed: Sep 14, 2026
Contributing guide: Contributing guide
Code of conduct: Code of conduct
Beginner labels: good first issue

Open All

151 open issues indexed

feat(connector): Add Opensearch source connector Open

connectors

apache/iggy#3503 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
feat(connector): Add Opensearch sink connector Open

connectors

apache/iggy#3504 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
IO Pressure Stall is near 100% Open

question

apache/iggy#3507 · 19 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
feat: OTLP Sink Connector Open

connectors

apache/iggy#3526 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
feat(connectors): add Redis sink connector for Iggy streams Open

connectors enhancement rust

apache/iggy#3530 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Kafka gateway: Kafka Metadata API (key 3) — broker and topic discovery via Iggy Open

gateways

apache/iggy#3534 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Kafka gateway: Kafka Produce API (key 0) — bridge to Iggy send_messages Open

gateways

apache/iggy#3535 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Kafka gateway: Kafka Fetch API (key 1) — bridge to Iggy offset-based polling Open

gateways

apache/iggy#3536 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Kafka gateway: Kafka ListOffsets API (key 2) — earliest/latest via Iggy high watermark Open

gateways

apache/iggy#3537 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Kafka gateway: Kafka CreateTopics API (key 19) — Iggy stream/topic provisioning Open

gateways

apache/iggy#3538 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Kafka gateway: Kafka gateway Phase 1 — docker-compose, E2E tests, and quick-start docs Open

gateways

apache/iggy#3539 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Kafka gateway: Design Consumer offset persistence strategy for Kafka gateway Phase 2 Open

gateways

apache/iggy#3540 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Kafka gateway: Kafka FindCoordinator, JoinGroup, SyncGroup, and Heartbeat APIs Open

gateways

apache/iggy#3541 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Kafka gateway: Kafka OffsetCommit and OffsetFetch with persisted consumer offsets Open

gateways

apache/iggy#3542 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Kafka gateway: Kafka LeaveGroup and consumer group rebalance semantics Open

gateways

apache/iggy#3543 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Kafka gateway: Kafka gateway Phase 2 — E2E tests with consumer groups Open

gateways

apache/iggy#3544 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Kafka gateway: Kafka transactional APIs — UNSUPPORTED_VERSION stub and idempotence docs Open

gateways

apache/iggy#3545 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Kafka gateway: Kafka DeleteTopics, DescribeConfigs, and AlterConfigs admin APIs Open

gateways

apache/iggy#3546 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Kafka gateway: Kafka DeleteRecords — trim topic to offset via Iggy retention Open

gateways

apache/iggy#3547 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Kafka gateway: Kafka DescribeGroups and ListGroups admin APIs Open

gateways

apache/iggy#3548 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Kafka gateway: Kafka SASL authentication bridge to Iggy users Open

gateways

apache/iggy#3549 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Kafka gateway: Kafka-to-Iggy migration guide — dual-write, cutover, decommission Open

gateways

apache/iggy#3550 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Kafka gateway: protocol parity tracking Open

gateways

apache/iggy#3560 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Draft MSSQL Connector Open

connectors good first issue

apache/iggy#3573 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
BDD Test Coverage Roadmap Open

test

apache/iggy#3609 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
CI: ship connector plugins in the `apache/iggy-connect` docker image Open

CI/CD connectors

apache/iggy#3614 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Expose structured `IggyError` in Python Open

good first issue python

apache/iggy#3618 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Add BDD test for event subscription Open

good first issue

apache/iggy#3630 · 3 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Flaky Java SDK test: AsyncConsumerGroupsTest.shouldHandleConcurrentJoinAndLeaveOperations fails with IggyResourceNotFoundException in CI Open

bug CI/CD

apache/iggy#3641 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Server panics/aborts on EMFILE (Too many open files) during index rebuild instead of failing gracefully Open

bug question server

apache/iggy#3645 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Go SDK should support reconnect and auto login configuration Open

go

apache/iggy#3650 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
SDK client state conflates transport and session dimensions; Authenticated is never reached Open

rust

apache/iggy#3651 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
feat(connector): Add Cassandra sink connector Open

connectors

apache/iggy#3683 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
add apache Fluss source connector Open

connectors

apache/iggy#3688 · 4 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
feat(connectors): add Apache Fluss sink connector Open

connectors enhancement rust

apache/iggy#3689 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
feat(security): Audit and remediate known CVEs / RustSec advisories in the dependency tree Open

connectors

apache/iggy#3698 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
feat(ci/cd): Add `cargo deny` as a pre-merge CI check Open

good first issue

apache/iggy#3699 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
feat(ci):Make production binaries auditable via `cargo auditable` Open

CI/CD

apache/iggy#3700 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
feat(connectors): shared retry_async helper in iggy_connector_sdk::retry Open

connectors

apache/iggy#3702 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
feat(connectors): add Apache Airflow trigger connector Open

connectors good first issue

apache/iggy#3715 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Add Amazon DynamoDB sink connector Open

connectors

apache/iggy#3731 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Binary protocol drops error payloads — clients rebuild `IggyError` with `Default` fields (`PartitionNotFound` always reports 0/0/0) Open

design postponed sdk

apache/iggy#3735 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
feat(connectors): Implement RabbitMQ / AMQP source & sink Open

connectors

apache/iggy#3747 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Python SDK: omitting `poll_interval` in `consumer_group()` polls with no delay — ~30% of a core on an idle topic, and nothing in Python documents it Open

bug python sdk

apache/iggy#3748 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
feat(connectors): Iggy Source/Sink Connector: Native Cluster-to-Cluster Replication Open

connectors good first issue

apache/iggy#3764 · 8 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
server: partition journal repair resurrects purged data after restart Open

bug

apache/iggy#3793 · 5 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
SDK: hand off the plugin-runtime worker during blocking source send callbacks Open

bug connectors rust

apache/iggy#3796 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
fix(connectors): runtime config API returns plugin credentials with auth disabled by default Open

bug connectors rust

apache/iggy#3802 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
feat(connectors): OTLP/gRPC source connector for logs, metrics and traces Open

connectors

apache/iggy#3815 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
connectors: Delta Lake Sink - allow concurrent writes across partitions Open

connectors

apache/iggy#3839 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026

apache/iggy

Get new issues in your inbox