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 8 days ago - 1 comment

#860 - Add bucketed pool for decompression

Pull Request - State: open - Opened by Sovietaced 14 days ago

#859 - Unexpected behavior with async produce context

Issue - State: open - Opened by echo8 14 days ago

#859 - Unexpected behavior with async produce context

Issue - State: open - Opened by echo8 14 days ago

#858 - Question: Memory usage pattern and potential leak

Issue - State: closed - Opened by Sovietaced 15 days ago - 7 comments

#857 - Bug | BasicLogger Panics When `len(keyvals)` is 1

Pull Request - State: open - Opened by vicluq 22 days ago - 2 comments

#856 - Bug: BasicLogger Panics When `len(keyvals)` is 1

Issue - State: open - Opened by vicluq 22 days ago

#855 - Question: should an error from EndTransaction re-initialize the producer ID/epoch?

Issue - State: open - Opened by rodaine 23 days ago - 2 comments
Labels: waiting

#854 - Bubble up batch processing failures when fetching

Issue - State: open - Opened by twmb 24 days ago
Labels: enhancement

#854 - Bubble up batch processing failures when fetching

Issue - State: open - Opened by twmb 24 days ago
Labels: enhancement

#853 - PauseFetchTopics/ResumeFetchTopics fetches old messages

Issue - State: closed - Opened by hugosjoberg 24 days ago - 4 comments
Labels: waiting

#852 - Question: Produce reordering protection

Issue - State: open - Opened by YellowCataclysm 27 days ago - 3 comments
Labels: enhancement

#851 - Add `ConfluentHeader.UpdateID()` API to sr package

Pull Request - State: closed - Opened by mihaitodor 29 days ago

#851 - Add `ConfluentHeader.UpdateID()` API to sr package

Pull Request - State: closed - Opened by mihaitodor 29 days ago

#850 - Specify the type for `sr.SoftDelete` and `sr.HardDelete`

Pull Request - State: closed - Opened by mihaitodor 29 days ago

#850 - Specify the type for `sr.SoftDelete` and `sr.HardDelete`

Pull Request - State: closed - Opened by mihaitodor 29 days ago

#849 - Add `CreateSchemaWithIDAndVersion()` to the sr package

Pull Request - State: open - Opened by mihaitodor 29 days 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 1 month ago

#842 - pkg/sr: require go 1.22

Pull Request - State: closed - Opened by twmb about 1 month ago
Labels: sr

#841 - CHANGELOG: note incoming release

Pull Request - State: closed - Opened by twmb about 1 month ago

#840 - Kafka 3.8.0

Pull Request - State: closed - Opened by twmb about 1 month ago

#839 - kgo: add EnsureProduceConnectionIsOpen

Pull Request - State: open - Opened by twmb about 1 month 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: 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 2 months ago - 2 comments

#820 - kprom: Multiple clients

Pull Request - State: open - Opened by lukasrynt 2 months ago

#819 - Change error string for sr.ResponseError

Issue - State: closed - Opened by weeco 2 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

#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

#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 3 months ago - 6 comments
Labels: waiting, has pr

#807 - kgo.LiveProduceConnection option for low-latency settings

Issue - State: open - Opened by deestan 3 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

#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