Ecosyste.ms: Issues

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

GitHub / segmentio/kafka-go issues and pull requests

#1230 - feat: sasl reauthentication

Pull Request - State: open - Opened by ertanden over 1 year ago - 9 comments

#1226 - not leave group if unnecessary

Pull Request - State: closed - Opened by zydovech over 1 year ago

#1225 - Fix FetchMessage return io.EOF error

Pull Request - State: closed - Opened by zydovech over 1 year ago - 3 comments

#1212 - getting frequent non-zero number of bytes remaining error during DescribeGroups

Issue - State: open - Opened by tarun-discovery over 1 year ago - 5 comments
Labels: bug

#1192 - check remaining bytes when marking batch as empty

Pull Request - State: open - Opened by zachxu42 over 1 year ago - 4 comments

#1182 - Intelligent health checks

Issue - State: closed - Opened by KasonBraley over 1 year ago
Labels: enhancement

#1169 - Flaky tests

Issue - State: open - Opened by petedannemann over 1 year ago - 2 comments
Labels: bug

#1150 - ReadMessage in loop getting 'read message error'

Issue - State: open - Opened by Scrubi19 over 1 year ago - 3 comments
Labels: bug

#1146 - Please provides api about producer or consumer interceptor

Issue - State: open - Opened by gotogotogo over 1 year ago - 2 comments
Labels: enhancement

#1142 - No error message on non-existent topic

Issue - State: closed - Opened by kostiamol over 1 year ago - 6 comments
Labels: bug

#1131 - Fix unnecessary topic metadata request

Pull Request - State: open - Opened by mhmtszr almost 2 years ago

#1130 - Security Bug

Issue - State: open - Opened by BigBunnie almost 2 years ago
Labels: bug

#1129 - Fix doc example for break from retryer on success

Pull Request - State: open - Opened by lanzay almost 2 years ago

#1128 - received empty assignments for group

Issue - State: open - Opened by wangrenyi almost 2 years ago - 2 comments
Labels: bug

#1126 - Synchronous `CommitMessages` is not always synchronous

Issue - State: open - Opened by iffyio almost 2 years ago
Labels: bug

#1125 - Fetch multiple messages at once

Pull Request - State: open - Opened by sergiusd almost 2 years ago

#1124 - DP-1383-Implement Sticky balancer

Pull Request - State: open - Opened by SaiPrasanna9 almost 2 years ago

#1122 - Can we expose `kafka.Reader` / Are there plans to deprecate `NewReader`?

Issue - State: open - Opened by jonathan-imprint almost 2 years ago
Labels: enhancement

#1120 - all: fix spelling errors

Pull Request - State: closed - Opened by kevinburkesegment almost 2 years ago - 1 comment

#1119 - KIP-546: Add Client Quota APIs

Pull Request - State: open - Opened by petedannemann almost 2 years ago - 1 comment

#1118 - Fix various typos and disfluencies

Pull Request - State: closed - Opened by PleasingFungus almost 2 years ago

#1117 - Remove the BatchQueue type

Pull Request - State: open - Opened by PleasingFungus almost 2 years ago - 6 comments

#1116 - Kafka reader stats code example

Issue - State: open - Opened by ehsansouri23 almost 2 years ago

#1115 - OffsetFetch() doesn't return topic info if topics is unset in request

Issue - State: open - Opened by hhahn-tw almost 2 years ago - 1 comment
Labels: bug

#1114 - CPU is full on consumer

Issue - State: closed - Opened by ltp217 almost 2 years ago
Labels: bug

#1113 - did not retry create topic when maxAttempt=10 and AllowAutoTopicCreation=true

Issue - State: open - Opened by carlclone almost 2 years ago
Labels: bug

#1110 - Don't invoke r.log() if not r.debug

Pull Request - State: closed - Opened by colega almost 2 years ago - 2 comments

#1109 - DescribeGroups hangs for inactive groups

Issue - State: open - Opened by petedannemann almost 2 years ago
Labels: bug

#1108 - Update SCRAM dependency

Pull Request - State: closed - Opened by SoMuchForSubtlety almost 2 years ago - 1 comment

#1107 - Fix handling for empty record batches

Pull Request - State: open - Opened by SoMuchForSubtlety almost 2 years ago - 4 comments

#1106 - Add count/sum to SummaryStats and DurationStats.

Pull Request - State: closed - Opened by pstibrany almost 2 years ago

#1105 - Using different values for MinBytes/MaxBytes has no effect

Issue - State: closed - Opened by forward32 almost 2 years ago - 1 comment
Labels: bug

#1104 - Configurable Message.Key and Message.Value bytes allocation functions

Pull Request - State: closed - Opened by colega almost 2 years ago - 4 comments

#1103 - add a new metric named `batchQueueTime` to track the batch time cost

Pull Request - State: closed - Opened by 3AceShowHand almost 2 years ago

#1101 - writer's `batchTime` metrics is inaccurate

Issue - State: closed - Opened by 3AceShowHand almost 2 years ago - 4 comments

#1100 - Handle Rotating TLS/SSL Certificates without Restart

Issue - State: open - Opened by jkratz55 almost 2 years ago - 1 comment

#1099 - Kafka cluster unavailable cause close the async writer blocked for a long time

Issue - State: open - Opened by 3AceShowHand almost 2 years ago - 3 comments
Labels: bug

#1098 - Why Reader cannot read message when setting groupid?

Issue - State: closed - Opened by afraidjpg almost 2 years ago - 3 comments

#1097 - A production-grade sample code on how to read message

Issue - State: open - Opened by silencer07 almost 2 years ago - 3 comments
Labels: enhancement

#1096 - Not omit error in logger

Pull Request - State: closed - Opened by itechdima almost 2 years ago - 3 comments

#1095 - Add DeleteGroups function to Client

Pull Request - State: closed - Opened by bgranvea almost 2 years ago - 1 comment

#1094 - Add Conn.WriteMulti function to produce to multiple topics/partitions

Pull Request - State: open - Opened by stevevls almost 2 years ago

#1093 - Observing "Group Authorization Failed" error for every 12 hours

Issue - State: open - Opened by gopi-bathala almost 2 years ago
Labels: bug

#1092 - InvalidRequest after TopicAlreadyExists was not thrown while creating topics.

Issue - State: open - Opened by Y-Wakuta almost 2 years ago
Labels: bug

#1091 - How to configure kafka parameters

Issue - State: closed - Opened by zhendliu almost 2 years ago - 1 comment
Labels: question

#1090 - Consumer group returns empty assignment if one of the topics doesn't exist

Issue - State: open - Opened by bgranvea almost 2 years ago - 2 comments
Labels: bug

#1089 - How to fetch uncommitted messages without triggering rebalance?

Issue - State: closed - Opened by mahditakrim almost 2 years ago - 5 comments

#1088 - New consumer group no topic and assignment problem

Issue - State: open - Opened by Abdulsametileri almost 2 years ago - 5 comments
Labels: bug

#1086 - Remove runtime.Gosched

Pull Request - State: closed - Opened by sejin-P almost 2 years ago

#1085 - Connect without Topic

Issue - State: closed - Opened by gaurishhs almost 2 years ago - 2 comments
Labels: enhancement

#1084 - Bump golang.org/x/net from 0.0.0-20220706163947-c90051bbdb60 to 0.7.0

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago - 1 comment
Labels: dependencies

#1083 - add finalizer to Reader

Pull Request - State: closed - Opened by rhansen2 almost 2 years ago

#1082 - How to use this library with bazel ?

Issue - State: closed - Opened by srilakshmikanthanp almost 2 years ago - 1 comment

#1080 - reader.CommitMessages()

Issue - State: closed - Opened by mahditakrim about 2 years ago - 2 comments

#1079 - Commit offsets with consumer group?

Issue - State: open - Opened by bgranvea about 2 years ago - 1 comment

#1077 - Change comment on MaxAttempts

Pull Request - State: closed - Opened by C-Pro about 2 years ago

#1076 - Does kafka.Reader support batch data pulling?

Issue - State: closed - Opened by 4zore4 about 2 years ago - 1 comment

#1075 - Kafka write timeout 1 sec vs batchsize 100 events

Issue - State: closed - Opened by tzookb about 2 years ago - 2 comments
Labels: bug

#1074 - Question: Should I use a new Client instance each time?

Issue - State: closed - Opened by Antonboom about 2 years ago - 2 comments
Labels: question

#1073 - fix unlimit batchQueue

Pull Request - State: open - Opened by jseparator about 2 years ago

#1072 - Dialer.DualStack ignored when set to false (and huge number of connections)

Issue - State: open - Opened by lbergesio about 2 years ago - 6 comments

#1071 - The consumer continues, even if the Topic is deleted

Issue - State: closed - Opened by kanhaiyaratsky about 2 years ago - 3 comments

#1070 - Update dialer.go

Pull Request - State: open - Opened by dxasu about 2 years ago - 1 comment

#1069 - Update dialer.go

Pull Request - State: closed - Opened by dxasu about 2 years ago

#1068 - Question: how to close a `Client` instance ?

Issue - State: closed - Opened by 3AceShowHand about 2 years ago - 1 comment

#1067 - SyncProducer blocked until BatchTimeout

Issue - State: closed - Opened by jseparator about 2 years ago - 1 comment

#1066 - Establishing connection latency problem when TLS and SCRAM Enabled

Issue - State: closed - Opened by Abdulsametileri about 2 years ago - 3 comments

#1065 - How to WriteMessage Via a Non-leader Connection

Issue - State: closed - Opened by davidzhongsydney about 2 years ago - 2 comments

#1064 - Add a method in *Writer that can return the delivery partiton and offset

Issue - State: closed - Opened by chazex about 2 years ago - 3 comments
Labels: enhancement

#1063 - Use buffer pool for decompressed buffer

Pull Request - State: closed - Opened by ashishkf about 2 years ago - 1 comment

#1062 - Avoid unnecessary string allocation while decoding

Pull Request - State: closed - Opened by mhmtszr about 2 years ago - 2 comments

#1061 - Memory leak in reflect package

Issue - State: closed - Opened by mhmtszr about 2 years ago - 12 comments
Labels: bug

#1060 - when I use SetReadDeadline(time.Time{}), The *Batch loop seems bolcked.

Issue - State: open - Opened by Mrmanbanpai about 2 years ago - 2 comments
Labels: bug

#1059 - add WriterData field to the message struct

Pull Request - State: closed - Opened by 3AceShowHand about 2 years ago - 8 comments

#1058 - Question: why implement `batchQueue` as a concurrency slice instead of use channel directly ?

Issue - State: closed - Opened by 3AceShowHand about 2 years ago - 2 comments
Labels: question

#1057 - controller broker port whit Reslover

Issue - State: closed - Opened by AlgerDu about 2 years ago - 1 comment
Labels: question

#1056 - Reader - ConsumerGroup Vs Partition

Issue - State: closed - Opened by git-dhyaneshpoojary about 2 years ago - 2 comments

#1055 - func (r *Reader) FetchMessages(ctx context.Context, maxSize int, timeout time.Interval) ([]Message, error)

Issue - State: closed - Opened by dashie about 2 years ago - 1 comment
Labels: enhancement

#1054 - Need a way to attach customized information to Message

Issue - State: closed - Opened by sdojjy about 2 years ago - 1 comment
Labels: enhancement

#1053 - [DRAFT] Reuse messages slice to avoid new allocations

Pull Request - State: closed - Opened by vitaly-m about 2 years ago - 4 comments

#1052 - Can I use kafka-go to get Topic's all value size?

Issue - State: closed - Opened by MasterYang7 about 2 years ago - 1 comment
Labels: enhancement

#1050 - Message accounting does not include size of headers.

Issue - State: open - Opened by kung-foo about 2 years ago - 1 comment
Labels: bug

#1049 - SASL handshake failed: EOF when TLS InsecureSkipVerify: true is not set

Issue - State: closed - Opened by lariskovski about 2 years ago - 1 comment
Labels: bug

#1047 - How to write message to desired partition ?

Issue - State: closed - Opened by emrecavunt about 2 years ago - 3 comments

#1046 - How to handle reconnect when kafka restart?

Issue - State: closed - Opened by dcy about 2 years ago - 3 comments
Labels: question

#1045 - retract v0.4.36-v0.4.37

Pull Request - State: closed - Opened by rhansen2 about 2 years ago

#1044 - Reader block indefinitely during kafka deployment

Issue - State: open - Opened by OlivierCazade about 2 years ago - 1 comment
Labels: bug

#1041 - Delay in Message read of order of ~10 seconds.

Issue - State: closed - Opened by lazyboson about 2 years ago - 4 comments
Labels: question

#1038 - WriteMessages memory leak

Issue - State: open - Opened by gokhankoc90 over 2 years ago - 7 comments
Labels: question

#1036 - Consumers are not consuming message after 15 hours

Issue - State: closed - Opened by vjakka-intel over 2 years ago - 8 comments
Labels: question

#1035 - Semver releases for SASL submodules

Issue - State: closed - Opened by achille-roussel over 2 years ago
Labels: enhancement

#1031 - Multiple consumers problem, only first one work!

Issue - State: closed - Opened by Mehrdad-Dadkhah over 2 years ago - 6 comments

#1029 - readNewBytes function consumes lot of memory

Issue - State: closed - Opened by gopi-bathala over 2 years ago - 2 comments
Labels: bug

#1025 - Integration with Opentelemetry standard.

Issue - State: open - Opened by maksim77 over 2 years ago - 8 comments
Labels: enhancement, question

#1019 - Bind custom parameter for Message to be called in Completion.

Issue - State: closed - Opened by edoger over 2 years ago - 1 comment
Labels: enhancement