msales / streams

79%

master: 78%

LAST BUILD ON BRANCH fan-out

branch: fan-out

CHANGE BRANCH

x

Reset

• fan-out
• (HEAD detached at v6.1.0)
• (HEAD detached at v6.1.0-rc1)
• (HEAD detached at v6.1.1)
• (HEAD detached at v6.1.2)
• (HEAD detached at v6.2.1)
• (HEAD detached at v6.3.0)
• TRK-474
• buffer
• bump
• context
• data-race-fix-vol-79
• deadlock-fix
• dependabot/go_modules/github.com/DATA-DOG/go-sqlmock-1.4.0
• dependabot/go_modules/github.com/DATA-DOG/go-sqlmock-1.4.1
• dependabot/go_modules/github.com/DATA-DOG/go-sqlmock-1.5.0
• dependabot/go_modules/github.com/Shopify/sarama-1.22.1
• dependabot/go_modules/github.com/Shopify/sarama-1.23.0
• dependabot/go_modules/github.com/Shopify/sarama-1.23.1
• dependabot/go_modules/github.com/Shopify/sarama-1.24.0
• dependabot/go_modules/github.com/Shopify/sarama-1.24.1
• dependabot/go_modules/github.com/Shopify/sarama-1.25.0
• dependabot/go_modules/github.com/Shopify/sarama-1.26.0
• dependabot/go_modules/github.com/Shopify/sarama-1.26.1
• dependabot/go_modules/github.com/Shopify/sarama-1.26.2
• dependabot/go_modules/github.com/Shopify/sarama-1.26.3
• dependabot/go_modules/github.com/Shopify/sarama-1.26.4
• dependabot/go_modules/github.com/Shopify/sarama-1.27.0
• dependabot/go_modules/github.com/Shopify/sarama-1.27.1
• dependabot/go_modules/github.com/Shopify/sarama-1.27.2
• dependabot/go_modules/github.com/msales/pkg/v3-3.16.2
• dependabot/go_modules/github.com/msales/pkg/v3-3.17.0
• dependabot/go_modules/github.com/msales/pkg/v3-3.17.1
• dependabot/go_modules/github.com/msales/pkg/v3-3.18.0
• dependabot/go_modules/github.com/msales/pkg/v3-3.19.0
• dependabot/go_modules/github.com/msales/pkg/v3-3.19.1
• dependabot/go_modules/github.com/msales/pkg/v3-3.21.2
• dependabot/go_modules/github.com/msales/pkg/v3-3.21.3
• dependabot/go_modules/github.com/msales/pkg/v4-4.1.1
• dependabot/go_modules/github.com/msales/pkg/v4-4.2.0
• dependabot/go_modules/github.com/msales/pkg/v4-4.3.0
• dependabot/go_modules/github.com/msales/pkg/v4-4.4.0
• dependabot/go_modules/github.com/pkg/errors-0.9.0
• dependabot/go_modules/github.com/pkg/errors-0.9.1
• dependabot/go_modules/github.com/stretchr/testify-1.4.0
• dependabot/go_modules/github.com/stretchr/testify-1.5.0
• dependabot/go_modules/github.com/stretchr/testify-1.5.1
• dependabot/go_modules/github.com/stretchr/testify-1.6.0
• dependabot/go_modules/github.com/stretchr/testify-1.6.1
• diagrams
• dockerfile-go-bump
• docs
• fix-issues
• github-actions
• go-1.17
• kafka_encoder_func
• logs-and-stats
• master
• message-test
• metastore-crash
• monitor
• new-meta-fix
• nil-decoder
• ring-buf
• sarama-cluster-out
• sasl-scram
• sink-fixes
• source
• sync
• timed-supervisor
• topology-flatten
• upgrade-major
• v1
• v2
• v2.4.0
• v2.5.0
• v2.5.1
• v2.5.2
• v2.5.3
• v2.5.4
• v2.6.0
• v3.0.0
• v3.1.0
• v3.2.0
• v3.2.1
• v4.0.0
• v4.0.1
• v5
• v5.0.0
• v5update
• v6.0.0
• v6.0.1
• vNext

Add FanOut stream builder and processor that branches stream into N streams.