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

#1368 - Reader without consumer group read at last offset

Issue - State: open - Opened by zekth 5 days ago
Labels: enhancement

#1367 - `int` Type Message Fields as Pointers

Issue - State: open - Opened by colechiumento-coreweave 20 days ago - 1 comment
Labels: enhancement

#1366 - [Question] OIDC auth for Kafka service being Confluent broker

Issue - State: open - Opened by manikyab 28 days ago
Labels: enhancement

#1365 - Fix: #1314 partition watcher doesn't reacts on partition number changing

Pull Request - State: open - Opened by arxon31 about 1 month ago - 2 comments

#1364 - How to Connect to Kafka with Kerberos Authentication

Issue - State: open - Opened by NingQue0920 about 1 month ago

#1363 - Allow setting Set ConsumerGroupConfig.Timeout from ReaderConfig

Pull Request - State: open - Opened by wwade about 1 month ago

#1362 - SASL handshake failed

Issue - State: open - Opened by j285627868 about 1 month ago - 1 comment

#1361 - topic partition not found

Issue - State: open - Opened by zty-f about 2 months ago
Labels: bug

#1360 - Compatibility with Apache Kafka 4.0

Issue - State: open - Opened by ijuma about 2 months ago - 9 comments
Labels: enhancement

#1359 - The same message is repeatedly sent to different fragments

Issue - State: closed - Opened by zty-f 2 months ago
Labels: bug

#1358 - Goroutines left behind after writing message even after closing writer

Issue - State: open - Opened by fjagugar 2 months ago - 1 comment
Labels: bug

#1356 - Is this repository maintained?

Issue - State: open - Opened by nachogiljaldo 2 months ago - 4 comments
Labels: enhancement

#1355 - How to configure idempotency？

Issue - State: closed - Opened by 1cccccc 3 months ago - 1 comment
Labels: bug

#1354 - FetchMessage Why submit offset automatically

Issue - State: open - Opened by yangtongbing 3 months ago - 7 comments
Labels: bug

#1353 - Close a consumer group reader take a long time.

Issue - State: open - Opened by lvhuat 3 months ago
Labels: bug

#1352 - EOF errors aren't retried by the Writer

Issue - State: open - Opened by scottybrisbane 3 months ago - 1 comment
Labels: bug

#1351 - Cannot listen to partition changes if Topics without subscriptions

Issue - State: open - Opened by fzj55 3 months ago
Labels: bug

#1350 - Optimize the murmur2 hash function

Pull Request - State: open - Opened by apocelipes 3 months ago - 2 comments

#1348 - fetchMessage receive some empty message

Issue - State: open - Opened by sunxiatao 3 months ago - 1 comment
Labels: bug

#1347 - fix: #429 respin making reader.read respect context closure

Pull Request - State: open - Opened by zekth 3 months ago - 5 comments

#1347 - fix: #429 respin making reader.read respect context closure

Pull Request - State: open - Opened by zekth 3 months ago - 5 comments

#1346 - Creating User

Issue - State: open - Opened by Cirilus 3 months ago
Labels: enhancement

#1346 - Creating User

Issue - State: closed - Opened by Cirilus 3 months ago - 1 comment
Labels: enhancement

#1342 - fix: A lot of unexpected EOF error when reading from partition

Pull Request - State: open - Opened by jarvanstack 4 months ago - 3 comments

#1341 - Report errors on writer close.

Pull Request - State: open - Opened by gemyago 4 months ago - 2 comments

#1340 - added-autoderive-batchSize--added-check-after-compression

Pull Request - State: open - Opened by timmyb32r 4 months ago - 6 comments

#1339 - Added SendPartialBatch Setting

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

#1338 - Added Azure Event Hubs Entra SASL Mechanism

Pull Request - State: open - Opened by tnewman-at-gm 4 months ago - 2 comments

#1336 - fix error msg in offsetdelete_test.go

Pull Request - State: open - Opened by pdeva 5 months ago

#1335 - Fix: Update OffsetCommit CommittedLeaderEpoch to v6

Pull Request - State: open - Opened by LeonHartley 5 months ago

#1333 - [QUESTION] Is WriteMessages transactional?

Issue - State: open - Opened by kpeu3i 5 months ago
Labels: bug

#1330 - Do not commit offsets for past generations if partition not owned

Pull Request - State: open - Opened by nachogiljaldo 5 months ago - 27 comments

#1329 - DT-14757: Fix writers closing issue

Pull Request - State: closed - Opened by mariosttass 5 months ago

#1327 - Support for replica placement constraints topic configuration

Issue - State: open - Opened by rca0 5 months ago
Labels: enhancement

#1326 - Setting Dialer in a new Writer requires doing a Lookup wrapper

Issue - State: open - Opened by ake-persson 6 months ago
Labels: enhancement

#1325 - Added Azure Event Hubs Entra SASL Mechanism

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

#1324 - Can the interval for requesting data from Kafka be changed?

Issue - State: open - Opened by dmitry-drozdov 6 months ago - 1 comment

#1323 - In ReaderStats struct, support GroupTopics if that's set

Issue - State: open - Opened by calvinbrown085 6 months ago
Labels: enhancement

#1322 - Fix capture loop variable in closure

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

#1321 - Fix redundant nil check of allocated address

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

#1320 - Events with same partition key are in different partitions

Issue - State: closed - Opened by maya-saias 6 months ago
Labels: bug

#1319 - Reader with ReaderGroup can lose first messages sent to the new topic

Issue - State: open - Opened by datacompboy 6 months ago - 1 comment
Labels: bug

#1317 - How to use Transactional API when using Writer instead of Dialer?

Issue - State: open - Opened by i-fix-retarded-bugs 7 months ago
Labels: enhancement

#1316 - Fix: Ignoring error UnknownTopicOrPartition in partitionWatcher

Pull Request - State: closed - Opened by arxon31 7 months ago

#1314 - No rebalance after empty assignment in consumer group

Issue - State: open - Opened by arxon31 7 months ago
Labels: bug

#1311 - Add ErrorType method to MessageTooLargeError

Pull Request - State: closed - Opened by AndrewShearBayer 7 months ago - 4 comments

#1310 - docker-compose.yml: specify AMD64 platform

Pull Request - State: open - Opened by kevinburkesegment 7 months ago

#1309 - Makefile: use docker compose not docker-compose

Pull Request - State: closed - Opened by kevinburkesegment 7 months ago

#1308 - Rebalances can lead to wrong lag being reported

Issue - State: open - Opened by nachogiljaldo 8 months ago - 2 comments
Labels: bug

#1307 - Closing kafka Writer during WriteMessages causes a potential hang

Issue - State: open - Opened by ionutboangiu 8 months ago
Labels: bug

#1306 - Getting Topic Information when UnknownTopicOrPartition happens

Issue - State: open - Opened by mhmtszr 8 months ago
Labels: enhancement

#1305 - #615 - allow specifying a listener for partition assignment changes

Pull Request - State: open - Opened by nachogiljaldo 8 months ago - 7 comments

#1304 - add prefix to coordinate host

Pull Request - State: closed - Opened by Ducthinh2603 8 months ago

#1303 - add prefix to coordinate host

Pull Request - State: closed - Opened by Ducthinh2603 8 months ago

#1302 - fix typo

Pull Request - State: closed - Opened by su5kk 8 months ago

#1301 - Multiple Consumers/Readers for different topics

Issue - State: open - Opened by avngzy 8 months ago - 1 comment

#1300 - Round robin balancer is not balancing topic-aware

Issue - State: open - Opened by CubicrootXYZ 8 months ago
Labels: bug

#1299 - Memory leak in writer

Issue - State: closed - Opened by alzrck 8 months ago - 1 comment
Labels: bug

#1298 - Control over failover between brokers

Issue - State: open - Opened by iSerganov 9 months ago
Labels: enhancement

#1297 - unsubscribe w/o passing whole list

Issue - State: open - Opened by ORESoftware 9 months ago
Labels: enhancement

#1296 - What should I do if I want to make bulk purchases on a topic?

Issue - State: open - Opened by jkwang-a 9 months ago - 1 comment
Labels: enhancement

#1293 - MessageTooLargeError is not conforming to `errors.Is`

Issue - State: closed - Opened by Tang8330 9 months ago - 3 comments
Labels: bug

#1292 - Fixes #874

Pull Request - State: open - Opened by kf6nux 9 months ago

#1290 - Authenticating with MSK SASL/SCRAM

Issue - State: closed - Opened by Tang8330 10 months ago - 1 comment
Labels: bug

#1289 - How to remove topics from client?

Issue - State: open - Opened by StarpTech 10 months ago - 1 comment
Labels: bug

#1287 - fix: avoid return io.UnexpectedEOF error while remain is zero

Pull Request - State: open - Opened by acynothia 10 months ago - 3 comments

#1286 - a lot of unexpected EOF error when reading from partition

Issue - State: open - Opened by acynothia 10 months ago - 3 comments
Labels: bug

#1285 - Making the producer backoff algorithm configurable

Issue - State: open - Opened by JSarvesh 10 months ago
Labels: enhancement

#1284 - Do not panic on errors

Issue - State: open - Opened by vbmithr 10 months ago - 1 comment
Labels: enhancement

#1282 - Remove trailing newlines from log messages

Pull Request - State: open - Opened by jackwilsdon 10 months ago

#1281 - Feture request: logger with different levels

Issue - State: open - Opened by iSerganov 10 months ago - 2 comments
Labels: enhancement

#1280 - Go1.16 cannot run tests

Issue - State: closed - Opened by loktarjugg 10 months ago - 2 comments

#1279 - Add auto topic creation to writer config

Pull Request - State: open - Opened by yogeshg 11 months ago

#1278 - AllowAutoTopicCreation does not exist in writer config, but only in the writer struct

Issue - State: open - Opened by yogeshg 11 months ago - 1 comment
Labels: enhancement

#1276 - Offset is going ahead and we are missing message with lag

Issue - State: open - Opened by NitinHsharma 11 months ago - 7 comments
Labels: bug

#1271 - Add flush method to writer

Pull Request - State: open - Opened by isaacd9 12 months ago

#1265 - Observability : Kafka Consumer/Producer metrics and tracing.

Issue - State: open - Opened by surenw-serenade about 1 year ago - 2 comments
Labels: enhancement

#1259 - Duplicate consumption occurs when join a new consumer and CommitInterval is configured

Issue - State: open - Opened by dalianzhu about 1 year ago - 3 comments
Labels: bug

#1258 - Asynchronous mode in kafka package not working

Issue - State: closed - Opened by HosseinRouhi79 about 1 year ago
Labels: enhancement

#1247 - logger: ensure compatibility with new log/slog package

Pull Request - State: open - Opened by kevinburkesegment about 1 year ago - 4 comments

#1241 - fix SetOffsetAt function, when used consumer group

Pull Request - State: closed - Opened by hallelujah-shih about 1 year ago

#1240 - How can I get the latest message in a topic?

Issue - State: closed - Opened by cocoza4 about 1 year ago - 3 comments

#1240 - How can I get the latest message in a topic?

Issue - State: closed - Opened by cocoza4 about 1 year ago - 3 comments