Ecosyste.ms: Issues

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

GitHub / bpot/poseidon issues and pull requests

#121 - Reconnect after failed

Pull Request - State: closed - Opened by michalbugno almost 6 years ago

#120 - Karafka as an alternative for Poseidon

Pull Request - State: open - Opened by mensfeld about 8 years ago - 5 comments

#119 - Recover when messages are removed from kafka

Pull Request - State: closed - Opened by alexcastano over 8 years ago - 1 comment

#118 - Commiting and fetching consumer offsets in Kafka

Issue - State: closed - Opened by mensfeld almost 9 years ago - 9 comments

#117 - Remove duplicate line in producer documentation

Pull Request - State: closed - Opened by Ben-M almost 9 years ago

#116 - Will poseidon implement async_producer in thre coming future?

Issue - State: open - Opened by liukgg almost 9 years ago - 1 comment

#115 - Trouble producing if too many brokers are down

Issue - State: open - Opened by Ben-M almost 9 years ago - 1 comment

#113 - A test--the checks can not pass even I donot change anything.

Pull Request - State: closed - Opened by liukgg almost 9 years ago

#112 - Will poseidon be maintained continuously in the coming future?

Issue - State: open - Opened by liukgg almost 9 years ago - 1 comment

#111 - optimize MessageToSend#initialize

Pull Request - State: closed - Opened by liukgg almost 9 years ago

#110 - Add seek_to_offset functionality to PartitionConsumer.

Pull Request - State: open - Opened by ovy-altiscale almost 9 years ago

#109 - Add Ruby implementation of Kafka's partition hasher (based on key). Test

Pull Request - State: open - Opened by ovy-altiscale almost 9 years ago - 3 comments

#108 - Use Zookeeper to discover brokers?

Issue - State: open - Opened by freenerd almost 9 years ago - 3 comments

#107 - Message#value seems to be escaped

Issue - State: open - Opened by krisleech almost 9 years ago - 5 comments

#106 - Kafka 0.9 support

Issue - State: open - Opened by mensfeld about 9 years ago - 1 comment

#105 - ignore under-replicated errors

Pull Request - State: closed - Opened by skandragon about 9 years ago - 1 comment

#104 - Does not handle a single down broker

Issue - State: open - Opened by skandragon about 9 years ago - 5 comments

#103 - Seeking a consumer by offset

Issue - State: open - Opened by ovy-altiscale about 9 years ago

#102 - Reset offset to :earliest_offset whenever OffsetOutOfRange happens

Pull Request - State: open - Opened by ymattw about 9 years ago

#101 - Raise explicit error for pending message send fail

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

#100 - Abh update gemspec

Pull Request - State: open - Opened by ABaldwinHunter about 9 years ago

#99 - update to pass over unavailable leaders

Pull Request - State: open - Opened by ABaldwinHunter about 9 years ago - 7 comments

#97 - Logging?

Issue - State: open - Opened by rayjohnson about 9 years ago - 1 comment

#96 - Add `#to_h` and `#to_hash` to `FetchedMessage`

Pull Request - State: closed - Opened by nepalez about 9 years ago

#95 - Correctly handle error cases around metadata fetching and message sending

Pull Request - State: open - Opened by drcapulet over 9 years ago - 5 comments

#94 - Is there no support for consumer groups?

Issue - State: open - Opened by messutied over 9 years ago - 2 comments

#93 - Obtaining topic metadata

Issue - State: open - Opened by skandragon over 9 years ago - 1 comment

#92 - Poseidon::Connection#read_response hides Timeout errors

Issue - State: open - Opened by ntl-bypass over 9 years ago - 2 comments

#91 - Missing messages in consumer

Issue - State: open - Opened by psamim over 9 years ago - 5 comments

#90 - Consumer does not appear to fetch all messages from a topic?

Issue - State: closed - Opened by daluu over 9 years ago - 1 comment

#88 - ReplicaNotAvailable can be safely ignored

Pull Request - State: open - Opened by arturmkrtchyan over 9 years ago - 6 comments

#87 - Fixing error handling for socket timeouts that occur due to a race-li…

Pull Request - State: open - Opened by StabbyCutyou over 9 years ago - 2 comments

#86 - Write to Kafka when loosing a Broker Connection

Issue - State: open - Opened by fegoa89 over 9 years ago

#85 - Fixing up consumer example confusion.

Pull Request - State: open - Opened by Interrupt over 9 years ago - 2 comments

#84 - send_messages should return false rather than raising an exception

Issue - State: closed - Opened by hadronzoo over 9 years ago - 2 comments
Labels: bug

#83 - Poseidon not fetching from within Redstorm

Issue - State: open - Opened by aliekens over 9 years ago - 1 comment

#82 - Is this repo still alive ?

Issue - State: closed - Opened by guizmaii over 9 years ago - 1 comment

#81 - Mark messages failed for un-retryable errors

Pull Request - State: closed - Opened by justingaylor over 9 years ago - 2 comments

#80 - Publisher topic generates successfully but message doesn't post.

Issue - State: open - Opened by dsalazar-carecloud almost 10 years ago - 9 comments

#79 - Nonblocking socket initialisation

Pull Request - State: open - Opened by szymonsobczak almost 10 years ago - 6 comments

#77 - bugfix: convert metadata refresh timeout to milliseconds in comparison

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

#76 - Improve partition_consumer docs formatting

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

#75 - PartitionConsumer documentation formatting fails

Issue - State: closed - Opened by rb2k almost 10 years ago - 2 comments

#74 - Allow request buffer to accept mixed encodings

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

#73 - Fix Encoding::CompatibilityError, force ASCII-8BIT for message value

Pull Request - State: closed - Opened by szymonsobczak about 10 years ago - 5 comments

#72 - Add :none option to :compression_codec

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

#71 - Correct a typo in an unknown codec message.

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

#70 - Accept socket_timeout_ms. Alphabetize valid options

Pull Request - State: closed - Opened by atharrison about 10 years ago - 4 comments

#69 - added a set_offset() method to partition_consumer.rb

Pull Request - State: open - Opened by bkao about 10 years ago - 4 comments

#68 - added a set_offset() method to partition_consumer.rb

Pull Request - State: closed - Opened by bkao about 10 years ago - 1 comment

#67 - socket_timeout_ms not a part of valid options

Issue - State: closed - Opened by s-vivek about 10 years ago

#66 - socket_timeout_ms option

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

#65 - When no logger is given, the null logger fallback will cause a NameError

Pull Request - State: closed - Opened by ryanwi about 10 years ago - 1 comment

#64 - Produce request failed on 0.8.1.1 cluster

Issue - State: open - Opened by ryanwi about 10 years ago - 8 comments

#63 - 0.0.4 broken for Kafka 0.8.1.1 partitioned topics

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

#62 - Investigating how to keep consumers up if a kafka node is lost

Issue - State: closed - Opened by ryanwi about 10 years ago - 1 comment

#61 - add require 'logger'

Pull Request - State: closed - Opened by shinjiikeda about 10 years ago - 1 comment

#60 - Fix Poseidon::Protocol::ProtocolStruct::EncodingError

Pull Request - State: closed - Opened by hadronzoo over 10 years ago - 2 comments

#59 - Poseidon::Protocol::ProtocolStruct::EncodingError

Issue - State: closed - Opened by hadronzoo over 10 years ago - 1 comment

#58 - kafka create topic api

Issue - State: closed - Opened by qudongfang over 10 years ago

#57 - Snappy

Pull Request - State: closed - Opened by tamird over 10 years ago - 5 comments

#56 - Fix deprecations

Pull Request - State: closed - Opened by tamird over 10 years ago - 3 comments

#55 - Define block open methods for Connection and BrokerPool

Pull Request - State: closed - Opened by zachmargolis over 10 years ago - 8 comments

#54 - Clean up connections inside of consumer_for_partition

Pull Request - State: closed - Opened by zachmargolis over 10 years ago - 2 comments

#53 - Expose topic as an attr_reader

Pull Request - State: closed - Opened by zachmargolis over 10 years ago - 3 comments

#52 - add support for snappy compression

Pull Request - State: closed - Opened by watersofoblivion over 10 years ago - 2 comments

#51 - Add a logger

Pull Request - State: closed - Opened by bpot over 10 years ago - 4 comments

#50 - Add PartitionConsumer#close

Pull Request - State: closed - Opened by bpot over 10 years ago - 2 comments

#49 - Run integration specs on travis-ci

Pull Request - State: open - Opened by bpot over 10 years ago - 7 comments

#48 - Consumer: block for messages by default

Pull Request - State: closed - Opened by bpot over 10 years ago - 2 comments

#47 - Raise Error on Metadata Failures

Pull Request - State: closed - Opened by bpot over 10 years ago - 5 comments

#46 - Add an optional response callback to Producer

Pull Request - State: open - Opened by bpot over 10 years ago - 8 comments

#45 - Producer: timeout option is :ack_timeout_ms not :request_timeout_ms

Pull Request - State: closed - Opened by bpot over 10 years ago - 2 comments

#44 - Handle request timeout in Producer

Issue - State: open - Opened by bpot over 10 years ago

#43 - Handle broker rebalances

Pull Request - State: closed - Opened by bpot over 10 years ago - 4 comments

#42 - Connection: Include host:port when raising a ConnectionFailedError

Pull Request - State: closed - Opened by bpot over 10 years ago - 2 comments

#40 - Partition Consumer - "fetch_one" option

Issue - State: closed - Opened by PaulBabka over 10 years ago - 2 comments

#35 - check produce responses for errors

Pull Request - State: open - Opened by sclasen over 10 years ago - 3 comments

#33 - What Kafka version is supported exactly? 0.8 doesn't seem to work.

Issue - State: closed - Opened by yankov over 10 years ago - 15 comments

#32 - Exception in ensure_connected is unhelpful

Issue - State: closed - Opened by hakutsuru over 10 years ago - 1 comment

#31 - timeouts not handled gracefully

Issue - State: closed - Opened by geoffrey-young over 10 years ago - 2 comments
Labels: bug

#29 - Distributed ConsumerGroups

Issue - State: closed - Opened by dim almost 11 years ago - 8 comments

#28 - Added snappy support

Pull Request - State: closed - Opened by dim almost 11 years ago - 11 comments

#27 - CPU consumption from consumers?

Issue - State: closed - Opened by bemurphy almost 11 years ago - 2 comments

#26 - Add Poseidon::Consumer

Pull Request - State: closed - Opened by bouk almost 11 years ago - 20 comments

#25 - handle broker rebalances

Issue - State: closed - Opened by sclasen almost 11 years ago - 3 comments

#22 - Ability to gracefully shutdown a consumer?

Issue - State: closed - Opened by aew about 11 years ago - 1 comment
Labels: enhancement

#21 - 1.0 Release

Issue - State: open - Opened by bpot about 11 years ago - 3 comments

#15 - Improve connection handling

Issue - State: closed - Opened by bpot about 11 years ago

#11 - encoding compatibility errors

Issue - State: closed - Opened by sclasen over 11 years ago - 7 comments

#7 - Message position overruns

Pull Request - State: closed - Opened by dougo-chris over 11 years ago - 7 comments

#6 - Fix round robin issue

Pull Request - State: closed - Opened by bpot over 11 years ago

#5 - raise ConnectionFailedError if reading the response gets EOF

Pull Request - State: closed - Opened by sclasen over 11 years ago - 2 comments

#1 - Handle new ack behavior in 0.8 correctly

Pull Request - State: closed - Opened by bpot over 11 years ago
Labels: bug