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
#861 - ability to get internal state via some event interface
Issue -
State: open - Opened by vtolstov 11 days ago
- 1 comment
#860 - Add bucketed pool for decompression
Pull Request -
State: open - Opened by Sovietaced 16 days ago
#859 - Unexpected behavior with async produce context
Issue -
State: open - Opened by echo8 17 days ago
#859 - Unexpected behavior with async produce context
Issue -
State: open - Opened by echo8 17 days ago
#858 - Question: Memory usage pattern and potential leak
Issue -
State: closed - Opened by Sovietaced 18 days ago
- 7 comments
#857 - Bug | BasicLogger Panics When `len(keyvals)` is 1
Pull Request -
State: open - Opened by vicluq 25 days ago
- 2 comments
#856 - Bug: BasicLogger Panics When `len(keyvals)` is 1
Issue -
State: open - Opened by vicluq 25 days ago
#855 - Question: should an error from EndTransaction re-initialize the producer ID/epoch?
Issue -
State: open - Opened by rodaine 26 days ago
- 2 comments
Labels: waiting
#854 - Bubble up batch processing failures when fetching
Issue -
State: open - Opened by twmb 27 days ago
Labels: enhancement
#854 - Bubble up batch processing failures when fetching
Issue -
State: open - Opened by twmb 27 days ago
Labels: enhancement
#853 - PauseFetchTopics/ResumeFetchTopics fetches old messages
Issue -
State: closed - Opened by hugosjoberg 27 days ago
- 4 comments
Labels: waiting
#852 - Question: Produce reordering protection
Issue -
State: open - Opened by YellowCataclysm about 1 month ago
- 3 comments
Labels: enhancement
#851 - Add `ConfluentHeader.UpdateID()` API to sr package
Pull Request -
State: closed - Opened by mihaitodor about 1 month ago
#851 - Add `ConfluentHeader.UpdateID()` API to sr package
Pull Request -
State: closed - Opened by mihaitodor about 1 month ago
#850 - Specify the type for `sr.SoftDelete` and `sr.HardDelete`
Pull Request -
State: closed - Opened by mihaitodor about 1 month ago
#850 - Specify the type for `sr.SoftDelete` and `sr.HardDelete`
Pull Request -
State: closed - Opened by mihaitodor about 1 month ago
#849 - Add `CreateSchemaWithIDAndVersion()` to the sr package
Pull Request -
State: open - Opened by mihaitodor about 1 month ago
- 1 comment
#848 - KIP-714
Issue -
State: open - Opened by twmb about 1 month ago
- 1 comment
#848 - KIP-714
Issue -
State: open - Opened by twmb about 1 month ago
- 1 comment
#847 - Closing consumer client hangs if unable to connect to broker
Issue -
State: closed - Opened by genzgd about 1 month ago
- 2 comments
Labels: waiting
#846 - Fix handling of invalid base offsets
Pull Request -
State: open - Opened by rodaine about 1 month ago
- 8 comments
#845 - Can we somehow mock the kafka client for unit testing?
Issue -
State: closed - Opened by vinayak-s-adimulam about 1 month ago
- 1 comment
#845 - Can we somehow mock the kafka client for unit testing?
Issue -
State: closed - Opened by vinayak-s-adimulam about 1 month ago
- 1 comment
#844 - Feat request: forwarding records unchanged to a producer client topic
Issue -
State: open - Opened by Nesze about 1 month ago
- 1 comment
Labels: enhancement
#844 - Feat request: forwarding records unchanged to a producer client topic
Issue -
State: open - Opened by Nesze about 1 month ago
- 1 comment
Labels: enhancement
#843 - pkg/kadm: bump go deps
Pull Request -
State: closed - Opened by twmb about 2 months ago
#842 - pkg/sr: require go 1.22
Pull Request -
State: closed - Opened by twmb about 2 months ago
Labels: sr
#841 - CHANGELOG: note incoming release
Pull Request -
State: closed - Opened by twmb about 2 months ago
#840 - Kafka 3.8.0
Pull Request -
State: closed - Opened by twmb about 2 months ago
#839 - kgo: add EnsureProduceConnectionIsOpen
Pull Request -
State: open - Opened by twmb about 2 months ago
#838 - kgo: do not add all topics to internal tps map when regex consuming
Pull Request -
State: closed - Opened by twmb about 2 months ago
Labels: patch
#837 - How do you specify the `member.id` of a consumer when using the `kgo.InstanceID()` client config option?
Issue -
State: closed - Opened by rchapin about 2 months ago
- 5 comments
Labels: waiting
#836 - kgo: add AssumeConsumersRequireStable()
Pull Request -
State: closed - Opened by twmb about 2 months ago
- 1 comment
Labels: minor
#835 - sr: add StatusCode to ResponseError, and message if the body is empty
Pull Request -
State: closed - Opened by twmb about 2 months ago
Labels: sr
#834 - kgo: ignore OOOSN where possible
Pull Request -
State: closed - Opened by twmb about 2 months ago
Labels: patch
#833 - Proto 3.8.0
Pull Request -
State: closed - Opened by twmb about 2 months ago
#832 - kgo: fix potential deadlock when reaching max buffered (records|bytes)
Pull Request -
State: closed - Opened by twmb about 2 months ago
Labels: patch
#831 - Deadlock producing during shutdown
Issue -
State: closed - Opened by asg0451 about 2 months ago
- 17 comments
Labels: bug, has pr
#830 - Request Errors metric support
Issue -
State: open - Opened by asg0451 2 months ago
- 5 comments
Labels: waiting
#829 - Add Opts method for sr.Client
Pull Request -
State: closed - Opened by andrewstucki 2 months ago
Labels: sr
#828 - Consuming from Kafka with some wait time in between fetches
Issue -
State: closed - Opened by adriangomez24 2 months ago
- 4 comments
#827 - `*kgo.Record` pooling support
Pull Request -
State: closed - Opened by ortuman 2 months ago
- 1 comment
Labels: waiting
#826 - Don't set nil config when seeding topics in kfake cluster
Pull Request -
State: closed - Opened by colega 2 months ago
- 2 comments
#825 - get rid of record allocation in `kgo.recordToRecord`
Pull Request -
State: closed - Opened by ortuman 2 months ago
#824 - `kgo.Record` pooling support
Pull Request -
State: closed - Opened by ortuman 2 months ago
#823 - high number of allocations in `kgo.recordToRecord` function
Issue -
State: open - Opened by ortuman 2 months ago
- 3 comments
Labels: waiting
#822 - Apparently invalid "connection refused" errors on Redpanda Cloud connection
Issue -
State: open - Opened by genzgd 2 months ago
- 1 comment
#822 - Apparently invalid "connection refused" errors on Redpanda Cloud connection
Issue -
State: closed - Opened by genzgd 2 months ago
- 5 comments
Labels: waiting
#821 - Fix typo in Record.ProducerID doc comment.
Pull Request -
State: open - Opened by seizethedave 2 months ago
#821 - Fix typo in Record.ProducerID doc comment.
Pull Request -
State: closed - Opened by seizethedave 2 months ago
#820 - kprom: Multiple clients
Pull Request -
State: open - Opened by lukasrynt 3 months ago
- 2 comments
#820 - kprom: Multiple clients
Pull Request -
State: open - Opened by lukasrynt 3 months ago
#819 - Change error string for sr.ResponseError
Issue -
State: closed - Opened by weeco 3 months ago
- 1 comment
Labels: enhancement, has pr, sr
#818 - strange issue with 1.17.0
Issue -
State: closed - Opened by vtolstov 3 months ago
- 3 comments
Labels: waiting
#817 - Direct consumer doesn't implement KIP-392
Issue -
State: closed - Opened by soundvibe 3 months ago
- 3 comments
Labels: waiting
#817 - Direct consumer doesn't implement KIP-392
Issue -
State: closed - Opened by soundvibe 3 months ago
- 3 comments
Labels: waiting
#816 - Fetch retry with COORDINATOR_NOT_AVAILABLE error never recovers
Issue -
State: open - Opened by genzgd 3 months ago
- 2 comments
Labels: waiting
#816 - Fetch retry with COORDINATOR_NOT_AVAILABLE error never recovers
Issue -
State: closed - Opened by genzgd 3 months ago
- 4 comments
Labels: waiting
#815 - kprom: Support for multiple clients
Issue -
State: open - Opened by lukasrynt 3 months ago
- 6 comments
Labels: enhancement, plugin, has pr
#814 - kadm: add `NewOffsetFromRecord` helper function
Pull Request -
State: closed - Opened by noamcohen97 3 months ago
- 1 comment
Labels: kadm
#814 - kadm: add `NewOffsetFromRecord` helper function
Pull Request -
State: open - Opened by noamcohen97 3 months ago
#813 - Potential memory leak in kgo/broker.go
Issue -
State: closed - Opened by sgtsquiggs 3 months ago
- 2 comments
#813 - Potential memory leak in kgo/broker.go
Issue -
State: closed - Opened by sgtsquiggs 3 months ago
- 2 comments
#812 - Fix typo in kgo.Client.ResumeFetchTopics() docs
Pull Request -
State: closed - Opened by mihaitodor 3 months ago
#812 - Fix typo in kgo.Client.ResumeFetchTopics() docs
Pull Request -
State: open - Opened by mihaitodor 3 months ago
#811 - Consumers stuck in endless rebalancing loop (consumer based off the goroutine-per-partition example)
Issue -
State: open - Opened by sgtsquiggs 3 months ago
#811 - Consumers stuck in endless rebalancing loop (consumer based off the goroutine-per-partition example)
Issue -
State: closed - Opened by sgtsquiggs 3 months ago
- 1 comment
#810 - `GetConsumeTopics` returns all topics when consuming via regex, not just the topics that are being consumed
Issue -
State: closed - Opened by twmb 3 months ago
- 2 comments
Labels: bug, has pr
#810 - `GetConsumeTopics` returns all topics when consuming via regex, not just the topics that are being consumed
Issue -
State: open - Opened by twmb 3 months ago
- 2 comments
Labels: bug
#809 - BrokerResponse too large
Issue -
State: closed - Opened by sakib-malik-7417 3 months ago
- 6 comments
#808 - sr: add support for using bearer tokens in client
Pull Request -
State: closed - Opened by weeco 3 months ago
#808 - sr: add support for using bearer tokens in client
Pull Request -
State: closed - Opened by weeco 3 months ago
#807 - kgo.LiveProduceConnection option for low-latency settings
Issue -
State: open - Opened by helgeholm 4 months ago
- 6 comments
Labels: waiting, has pr
#807 - kgo.LiveProduceConnection option for low-latency settings
Issue -
State: open - Opened by deestan 4 months ago
- 4 comments
Labels: waiting
#806 - Remove unnecessary condition in if statements
Pull Request -
State: closed - Opened by chakku000 4 months ago
Labels: patch
#806 - Remove unnecessary condition in if statements
Pull Request -
State: open - Opened by chakku000 4 months ago
Labels: patch
#805 - Bump epoch if the log_start_offset advanced and broker returned unknown_producer_id
Issue -
State: open - Opened by twmb 4 months ago
Labels: enhancement
#805 - Bump epoch if the log_start_offset advanced and broker returned unknown_producer_id
Issue -
State: closed - Opened by twmb 4 months ago
Labels: enhancement, has pr, patch
#804 - Update GroupMetadataKey / GroupMetadataValue
Issue -
State: open - Opened by twmb 4 months ago
Labels: enhancement
#804 - Update GroupMetadataKey / GroupMetadataValue
Issue -
State: closed - Opened by twmb 4 months ago
Labels: enhancement, has pr
#803 - fetching: export utilities for decompressing and parsing partition fetch responses
Pull Request -
State: open - Opened by dimitarvdimitrov 4 months ago
- 3 comments
Labels: waiting
#803 - fetching: export utilities for decompressing and parsing partition fetch responses
Pull Request -
State: open - Opened by dimitarvdimitrov 4 months ago
- 3 comments
Labels: waiting
#802 - Clarify bytes metrics description
Pull Request -
State: closed - Opened by pracucci 4 months ago
- 1 comment
#802 - Clarify bytes metrics description
Pull Request -
State: closed - Opened by pracucci 4 months ago
- 1 comment
#801 - Question regarding manual commit example
Issue -
State: closed - Opened by Iadgarov 4 months ago
- 1 comment
#801 - Question regarding manual commit example
Issue -
State: closed - Opened by Iadgarov 4 months ago
- 1 comment
#800 - Cache metadata more
Issue -
State: open - Opened by twmb 4 months ago
- 1 comment
Labels: enhancement
#800 - Cache metadata more
Issue -
State: open - Opened by twmb 4 months ago
- 2 comments
Labels: enhancement
#799 - Decoding GroupMetadataValueMember fails
Issue -
State: closed - Opened by weeco 4 months ago
- 1 comment
#799 - Decoding GroupMetadataValueMember fails
Issue -
State: closed - Opened by weeco 4 months ago
- 1 comment
#798 - Connecting franz-go with a confluent kafka cloud cluster
Issue -
State: closed - Opened by sashithaf16 4 months ago
- 2 comments
#798 - Connecting franz-go with a confluent kafka cloud cluster
Issue -
State: closed - Opened by sashithaf16 4 months ago
- 2 comments
#797 - sr: fix body of cl.SetMode
Pull Request -
State: closed - Opened by r-vasquez 4 months ago
#797 - sr: fix body of cl.SetMode
Pull Request -
State: closed - Opened by r-vasquez 4 months ago
#796 - Want to delete the consumer group after processing records from kafka
Issue -
State: closed - Opened by puneetjindal1997 4 months ago
- 1 comment
#796 - Want to delete the consumer group after processing records from kafka
Issue -
State: closed - Opened by puneetjindal1997 4 months ago
- 1 comment
#795 - Imbalanced Partition Assignment to Consumers Per Topic
Issue -
State: closed - Opened by mehranmeidani 4 months ago
- 1 comment
#795 - Imbalanced Partition Assignment to Consumers Per Topic
Issue -
State: closed - Opened by mehranmeidani 4 months ago
- 1 comment
#794 - kgo: add TopicID to the FetchTopic type
Pull Request -
State: open - Opened by twmb 4 months ago
- 1 comment
Labels: minor
#794 - kgo: add TopicID to the FetchTopic type
Pull Request -
State: closed - Opened by twmb 4 months ago
- 2 comments
Labels: minor