Shopify / sarama

Watch 410
Star 6.2k
Fork 1.1k

Code
Issues 101
Pull requests 24
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

101 Open 758 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

ClusterAdmin api gets error broken pipe after about 10 min of inactivity.

#1796 opened Sep 5, 2020 by moneesingh

how to set max.poll.interval.ms

#1795 opened Sep 3, 2020 by NessGo

Consider switching default Kafka version

#1787 opened Aug 21, 2020 by stanislavkozlovski

Exporting decoders

#1786 opened Aug 19, 2020 by Vemmy124

Partition consumer hangs when reading messages from topic

#1782 opened Aug 19, 2020 by akamensky

Write an consumer with consumer group and manually commit offset by partition (example)

#1780 opened Aug 17, 2020 by ut0mt8

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

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

Previous 1 2 3 4 5 Next

Previous Next

ProTip! Follow long discussions with comments:>50.