Shopify / sarama

Watch 411
Star 6.1k
Fork 1.1k

Code
Issues 96
Pull requests 19
Actions
Projects
Wiki
Security
Insights

Code
Issues
Pull requests
Actions
Projects
Wiki
Security
Insights

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Pick a username

Email Address

Password

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

96 Open 753 Closed

Author

Filter by author

Label

Filter by label

Use alt + click/return to exclude labels.

Projects

Filter by project

Milestones

Filter by milestone

Assignee

Filter by who’s assigned

Sort

Sort by

Newest Oldest Most commented Least commented Recently updated Least recently updated

Most reactions

Getting runtime: invalid pc-encoded table f=runtime.goexit with sarama package

#1777 opened Aug 13, 2020 by VijayBhaskar

[Question] How to Gracefully shutdown Kafka consumer process

#1776 opened Aug 12, 2020 by alok87

More cpu usage for publishing a message using sarama

#1773 opened Aug 6, 2020 by VijayBhaskar

Question: is it safe to attach more than one PartitionConsumer on the same Consumer?

#1772 opened Aug 6, 2020 by tarokker

Infinite loop for NewConsumer when Consumer Group is not authorized

#1771 opened Aug 5, 2020 by csreesan

Update confluentPlatformVersion to include Kafka 2.6 tests

#1770 opened Aug 5, 2020 by bai

How to add delay to processing of message?

#1768 opened Aug 4, 2020 by aksJain0

Add mock for the consumer group

#1767 opened Jul 30, 2020 by XSAM

Question: Does sarama support self-signed certificates with verification enabled?

#1766 opened Jul 27, 2020 by wcallgair

Batch-deleting topics with ClusterAdmin

#1765 opened Jul 27, 2020 by karenin-overseas

Since allow the consumer to disable auto-commit offsets, so how to commit offset manually?

#1764 opened Jul 27, 2020 by bglmmz

producer create by sarama.NewSyncProducer is thread safe ?

#1761 opened Jul 25, 2020 by widon1104

Please add some example of producer transaction!

#1760 opened Jul 23, 2020 by lvhuat

ReadCommitted dead loop to fetch empty MessageSetSize

#1759 opened Jul 21, 2020 by sundy-li

Unexpected user-specified time limit error still occurs

#1758 opened Jul 21, 2020 by kimtree

several consumer group can't consume

#1757 opened Jul 21, 2020 by luckyweiwei

commit offset manually when using a single consumer?

#1756 opened Jul 21, 2020 by bglmmz

Improving usage of breaker in sarama

#1755 opened Jul 20, 2020 by GiedriusS

Providing better metrics support in Sarama enhancement

#1754 opened Jul 19, 2020 by varun06

Performance degradation when Kafka connection breaks

#1751 opened Jul 13, 2020 by ajithcnambiar

filebeat can not push to kafka

#1749 opened Jul 11, 2020 by ClementeGao

How to read metadata, previously set using ConsumerGroupSession.MarkOffset()

#1748 opened Jul 10, 2020 by harshana-pickme

Mock broker set message header

#1746 opened Jul 9, 2020 by XSAM

Behavior : Messages marked for deletion

#1745 opened Jul 8, 2020 by harshana-pickme

There is a Flaky test in CI

#1742 opened Jul 5, 2020 by varun06

Previous 1 2 3 4 Next

Previous Next

ProTip! What’s not been updated in a month: updated:<2020-07-15.