kafka-go
kafka-go copied to clipboard
segmentio
Kafka library in Go
**Describe the solution you'd like** Once #223 is merged, we can add support for GSSAPI (Kerberos) authentication. **Supporting documentation** https://cwiki.apache.org/confluence/display/KAFKA/KIP-43%3A+Kafka+SASL+enhancements https://docs.confluent.io/current/kafka/authentication_sasl/authentication_sasl_gssapi.html
I am not considering this a bug, rather something to understand why as I have faced bad symptoms. **Describe the bug** For every WriteMessage, Kafka client requests all Topics from...
This moves logic for discovering partitions on a topic from `Writer` to `Client`, which should make it easier to write lower-level programs that don't need batching functionality. If accepted, this...
Reader groups are a way of consuming messages from multiple partitions without consumer groups. This is useful, e.g. when you are using compacted topics and don't replicate the state from...
This provides the controller connection for the kafka cluster which is required to avoid error 41 when attempting to use segmentio to create topics on a connection to a node...
This pull request proposes an implementation of client-side support for periodic re-authentication, as defined [here](https://cwiki.apache.org/confluence/display/KAFKA/KIP-368%3A+Allow+SASL+Connections+to+Periodically+Re-Authenticate) Note that this functionality is needed in order to properly support [SASL/OAUTHBEARER authentication](https://github.com/segmentio/kafka-go/issues/238) Protocol reference:...
Closes segmentio/kafka-go#428. --- This change is [](https://reviewable.io/reviews/segmentio/kafka-go/429)
We have a use case where seeing the lag for a given topic/partition is almost critical. kafka-go already tracks this internally, and it would be good to be able to...
**Describe the solution you'd like** Now and then, I need to read messages from a topic with no need for consumer groups, because we want to: - Have all instances...