Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / twmb/franz-go issues and pull requests

#793 - CHANGELOG: update for 1.17.1

Pull Request - State: closed - Opened by twmb 4 months ago

#793 - CHANGELOG: update for 1.17.1

Pull Request - State: closed - Opened by twmb 4 months ago

#792 - kgo: allow record ctx cancelation to propagate a bit more

Pull Request - State: closed - Opened by twmb 4 months ago
Labels: patch

#792 - kgo: allow record ctx cancelation to propagate a bit more

Pull Request - State: closed - Opened by twmb 4 months ago
Labels: patch

#791 - How to delete offset when message got consumed?

Issue - State: closed - Opened by puneetjindal1997 4 months ago - 4 comments

#791 - How to delete offset when message got consumed?

Issue - State: closed - Opened by puneetjindal1997 4 months ago - 4 comments

#790 - fetch using topic id

Issue - State: closed - Opened by arjunnair1997 4 months ago - 3 comments
Labels: enhancement, minor, has pr

#790 - fetch using topic id

Issue - State: open - Opened by arjunnair1997 4 months ago - 3 comments
Labels: enhancement, has pr

#789 - kgo: export the wrapped error from ErrGroupSession

Pull Request - State: open - Opened by sbuliarca 4 months ago - 5 comments

#789 - kgo: export the wrapped error from ErrGroupSession

Pull Request - State: closed - Opened by sbuliarca 4 months ago - 6 comments
Labels: minor

#788 - Is there a way to test kgo.Opts returned from wrapper function?

Issue - State: closed - Opened by sappusaketh 4 months ago - 1 comment

#787 - kgo: fix deadlock in Produce when using MaxBufferedBytes

Pull Request - State: closed - Opened by twmb 4 months ago - 2 comments
Labels: patch

#787 - kgo: fix deadlock in Produce when using MaxBufferedBytes

Pull Request - State: closed - Opened by twmb 4 months ago - 2 comments
Labels: patch

#786 - kgo sink: fix read/write race for recBatch.canFailFromLoadErrs

Pull Request - State: closed - Opened by twmb 4 months ago
Labels: patch

#786 - kgo sink: fix read/write race for recBatch.canFailFromLoadErrs

Pull Request - State: closed - Opened by twmb 4 months ago
Labels: patch

#785 - Data Race: concurrent access to recBatch.canFailFromLoadErrs during retry errors

Issue - State: closed - Opened by rodaine 4 months ago - 4 comments
Labels: bug, has pr

#785 - Data Race: concurrent access to recBatch.canFailFromLoadErrs during retry errors

Issue - State: closed - Opened by rodaine 4 months ago - 4 comments
Labels: bug, has pr

#783 - README: `kafka-go` also works with Confluent Platform

Pull Request - State: closed - Opened by hhromic 4 months ago

#782 - Add Conduit to list of users

Pull Request - State: closed - Opened by hariso 4 months ago - 2 comments

#782 - Add Conduit to list of users

Pull Request - State: closed - Opened by hariso 4 months ago - 2 comments

#781 - fix setting lz4 compression levels

Pull Request - State: closed - Opened by asg0451 4 months ago - 8 comments
Labels: patch

#781 - fix setting lz4 compression levels

Pull Request - State: closed - Opened by asg0451 4 months ago - 8 comments
Labels: patch

#780 - Error on kadm/UserSCRAMs calls with redpanda

Issue - State: closed - Opened by dmytzo 4 months ago - 3 comments

#780 - Error on kadm/UserSCRAMs calls with redpanda

Issue - State: closed - Opened by dmytzo 4 months ago - 3 comments

#779 - deadLock in produce

Issue - State: closed - Opened by Imran-imtiaz48 4 months ago - 2 comments
Labels: duplicate

#779 - deadLock in produce

Issue - State: closed - Opened by Imran-imtiaz48 4 months ago - 2 comments
Labels: duplicate

#778 - Unable to specify LZ4 compression level

Issue - State: closed - Opened by asg0451 4 months ago - 3 comments
Labels: bug, has pr

#778 - Unable to specify LZ4 compression level

Issue - State: closed - Opened by asg0451 4 months ago - 3 comments
Labels: bug, has pr

#777 - Deadlock in Produce() / TryProduce() when kgo.MaxBufferedBytes() is configured

Issue - State: closed - Opened by pracucci 5 months ago - 2 comments
Labels: bug, has pr

#777 - Deadlock in Produce() / TryProduce() when kgo.MaxBufferedBytes() is configured

Issue - State: closed - Opened by pracucci 5 months ago - 2 comments
Labels: bug, has pr

#776 - github.com/twmb/franz-go/pkg/sr#Client.AllSchemas 404 not found

Issue - State: closed - Opened by randomizedcoder 5 months ago - 3 comments

#775 - Add ShardErrors.Unwrap() support

Pull Request - State: closed - Opened by pracucci 5 months ago - 1 comment
Labels: kadm

#775 - Add ShardErrors.Unwrap() support

Pull Request - State: closed - Opened by pracucci 5 months ago - 2 comments
Labels: kadm

#774 - refactor: replace sliceWriter with bytes.Buffer and use it in decompression

Pull Request - State: closed - Opened by kalbhor 5 months ago
Labels: patch

#774 - refactor: replace sliceWriter with bytes.Buffer and use it in decompression

Pull Request - State: closed - Opened by kalbhor 5 months ago
Labels: patch

#773 - add test

Pull Request - State: closed - Opened by C-Pro 5 months ago - 2 comments

#773 - add test

Pull Request - State: closed - Opened by C-Pro 5 months ago - 2 comments

#772 - Update `README.md` to add `EasyPost` as a user

Pull Request - State: closed - Opened by kev-chien 5 months ago - 1 comment

#772 - Update `README.md` to add `EasyPost` as a user

Pull Request - State: closed - Opened by kev-chien 5 months ago - 1 comment

#771 - Retry fetched records on handle error

Issue - State: closed - Opened by dro-sh 5 months ago - 1 comment

#771 - Retry fetched records on handle error

Issue - State: closed - Opened by dro-sh 5 months ago - 1 comment

#770 - Broker Throttling

Issue - State: closed - Opened by jdenquin 5 months ago

#770 - Broker Throttling

Issue - State: closed - Opened by jdenquin 5 months ago

#769 - RequestTimeoutOverhead appears to override Context cancellation

Issue - State: closed - Opened by JFlath 6 months ago - 5 comments

#769 - RequestTimeoutOverhead appears to override Context cancellation

Issue - State: closed - Opened by JFlath 6 months ago - 5 comments

#768 - Documentation request / question

Issue - State: closed - Opened by asg0451 6 months ago - 1 comment

#768 - Documentation request / question

Issue - State: closed - Opened by asg0451 6 months ago - 1 comment

#767 - kfake: Drop topic configuration validation

Pull Request - State: closed - Opened by jan-g 6 months ago - 1 comment

#767 - kfake: Drop topic configuration validation

Pull Request - State: closed - Opened by jan-g 6 months ago - 1 comment

#766 - kfake: Support custom topic configuration validation

Pull Request - State: closed - Opened by jan-g 6 months ago - 1 comment

#766 - kfake: Support custom topic configuration validation

Pull Request - State: closed - Opened by jan-g 6 months ago - 1 comment

#765 - Feature request: expose metadata to the user

Issue - State: closed - Opened by asg0451 6 months ago - 2 comments

#765 - Feature request: expose metadata to the user

Issue - State: closed - Opened by asg0451 6 months ago - 2 comments

#763 - Question: Why does kgo.StopProducerOnDataLossDetected() exist?

Issue - State: closed - Opened by asg0451 6 months ago - 2 comments

#763 - Question: Why does kgo.StopProducerOnDataLossDetected() exist?

Issue - State: closed - Opened by asg0451 6 months ago - 2 comments

#762 - kgo: add log for preferred replicas

Pull Request - State: closed - Opened by twmb 6 months ago
Labels: patch

#762 - kgo: add log for preferred replicas

Pull Request - State: closed - Opened by twmb 6 months ago
Labels: patch

#761 - kgo sink: do not back off on certain edge case

Pull Request - State: closed - Opened by twmb 6 months ago
Labels: patch

#760 - kgo: add AllowRebalance and CloseAllowingRebalance to GroupTransactSession

Pull Request - State: open - Opened by twmb 6 months ago
Labels: minor

#760 - kgo: add AllowRebalance and CloseAllowingRebalance to GroupTransactSession

Pull Request - State: closed - Opened by twmb 6 months ago
Labels: minor

#759 - kadm: add ErrMessage to all types it was missing from

Pull Request - State: closed - Opened by twmb 6 months ago
Labels: kadm

#759 - kadm: add ErrMessage to all types it was missing from

Pull Request - State: closed - Opened by twmb 6 months ago
Labels: kadm

#758 - kgo: ignore aborted txns if using READ_UNCOMMITTED

Pull Request - State: closed - Opened by twmb 6 months ago

#758 - kgo: ignore aborted txns if using READ_UNCOMMITTED

Pull Request - State: closed - Opened by twmb 6 months ago

#757 - Is there a way to limit consumer PollRecords buffered fetches by size?

Issue - State: closed - Opened by genzgd 6 months ago - 1 comment

#757 - Is there a way to limit consumer PollRecords buffered fetches by size?

Issue - State: closed - Opened by genzgd 6 months ago - 1 comment

#756 - ProduceSync returning "context canceled" error when parent context hasn't been cancelled

Issue - State: closed - Opened by saholman 6 months ago - 5 comments
Labels: waiting

#756 - ProduceSync returning "context canceled" error when parent context hasn't been cancelled

Issue - State: closed - Opened by saholman 6 months ago - 5 comments
Labels: waiting

#755 - Fix typo (update default Acks in comment) in config.go

Pull Request - State: closed - Opened by Maks-D 6 months ago - 1 comment

#755 - Fix typo (update default Acks in comment) in config.go

Pull Request - State: closed - Opened by Maks-D 6 months ago - 1 comment

#754 - Use EOS sessions with BlockRebalanceOnPoll

Issue - State: closed - Opened by kahartma 6 months ago - 4 comments
Labels: enhancement, has pr

#754 - Use EOS sessions with BlockRebalanceOnPoll

Issue - State: open - Opened by kahartma 6 months ago - 3 comments
Labels: enhancement

#753 - GroupTransactSession Close hangs, preventing restart

Issue - State: closed - Opened by iamnoah 6 months ago - 5 comments
Labels: enhancement, minor, has pr

#753 - GroupTransactSession Close hangs, preventing restart

Issue - State: open - Opened by iamnoah 6 months ago - 4 comments
Labels: enhancement, has pr

#752 - How to fetch zero records without waiting

Issue - State: closed - Opened by muxmuse 6 months ago - 1 comment

#752 - How to fetch zero records without waiting

Issue - State: closed - Opened by muxmuse 6 months ago - 1 comment

#751 - Confluent: Unable to create a topic due to policy violation

Issue - State: closed - Opened by Amogh-Bharadwaj 6 months ago - 3 comments
Labels: enhancement, has pr

#751 - Confluent: Unable to create a topic due to policy violation

Issue - State: closed - Opened by Amogh-Bharadwaj 6 months ago - 3 comments
Labels: enhancement, has pr

#750 - [Question] Checking client state before using it

Issue - State: closed - Opened by bentcoder 6 months ago - 1 comment

#750 - [Question] Checking client state before using it

Issue - State: closed - Opened by bentcoder 6 months ago - 1 comment

#749 - Clarify producer batch config, once again

Issue - State: closed - Opened by kirilldd2 6 months ago - 3 comments

#749 - Clarify producer batch config, once again

Issue - State: closed - Opened by kirilldd2 6 months ago - 3 comments

#747 - docs: update SaramaCompatHasher documentation

Pull Request - State: closed - Opened by rrreeezzz 6 months ago - 1 comment

#746 - Produce Latency Spikes Due To Race Condition When Brokers Are Scaled Down

Issue - State: closed - Opened by aratz-lasa 6 months ago - 8 comments
Labels: has pr

#745 - SR: prevent panic when no decode function is registered

Pull Request - State: closed - Opened by lovromazgon 6 months ago - 1 comment

#744 - kadm: improve Lag calculation to account for log-start-offset being non-zero

Pull Request - State: closed - Opened by twmb 6 months ago
Labels: kadm

#743 - pkg/sr: move SerdeHeader arg before id, index

Pull Request - State: closed - Opened by twmb 6 months ago

#742 - pkg/sr: touchups

Pull Request - State: closed - Opened by twmb 6 months ago

#741 - kgo: bump consumer_direct_test timeout, make non-parallel

Pull Request - State: closed - Opened by twmb 6 months ago

#740 - Final v1.17

Pull Request - State: closed - Opened by twmb 6 months ago

#739 - kversions: skip many more broker-to-broker keys

Pull Request - State: closed - Opened by twmb 6 months ago

#738 - kgo.Offset: add AtCommitted()

Pull Request - State: closed - Opened by twmb 6 months ago

#737 - pkg/kgo: re-add fetch-canceled partitions AFTER the user callback

Pull Request - State: closed - Opened by twmb 6 months ago

#736 - kgo: avoid / wakeup lingering if we hit max bytes or max records

Pull Request - State: closed - Opened by twmb 6 months ago

#735 - eos example: avoid short-circuit logic

Pull Request - State: closed - Opened by twmb 6 months ago