Eric Kennedy
Eric Kennedy
When changing from SASL to TLS authentication, the latest offset is not stored in the consumer group
So I am using `franz-go` via benthos. Specifically this module: https://www.benthos.dev/docs/components/inputs/kafka_franz/ One thing I noticed is if i changed my authentication method from sasl to tls, my consumer group sometimes...
Looks like I am having some white space issue. My text editor is saying spaces: 4. What are you using? edit: I think I resolved the whitespace issues. Found this...
Manually tested and it looks pretty good. If the schema is: ``` { "type": "record", "name": "heartbeat_v3", "namespace": "outbox_events", "fields": [ { "name": "heartbeat", "type": [ "null", "int" ], "default":...
When sorting by timestamp by newest first, cannot seem to return latest events. Instead the partition/offset is still prioritized. Furthermore it seems that setting a timestamp does not filter out...
**Describe the bug** So when I use kafka go as a writer, I will randomly get the error `"[3] Unknown Topic Or Partition: the request is for a topic or...
It would be great to use this feature: https://cwiki.apache.org/confluence/display/KAFKA/KIP-429%3A+Kafka+Consumer+Incremental+Rebalance+Protocol I believe it is supported in other clients: https://pkg.go.dev/github.com/Shopify/sarama#StickyBalanceStrategyName https://pkg.go.dev/github.com/twmb/franz-go/pkg/kgo#CooperativeStickyBalancer But I couldn't find it in this one.
Take 2 of: https://github.com/benthosdev/benthos/pull/1361 Main purpose for upgrading is to handle a bug I was having in an older version of franz-go that I have at least yet to reproduce...
When creating a consumer you specify what balancer strategy to use: https://pkg.go.dev/github.com/Shopify/sarama#Config.Consumer In other clients such a parameter is an array of balancers in case other consumers don't implement one...
* **asyncpg version**: 0.27.0 * **PostgreSQL version**: 15.1 * **Do you use a PostgreSQL SaaS? If so, which? Can you reproduce the issue with a local PostgreSQL install?**: * **Python...
I am wondering if there are any noticeable bugs in this code? I am running into some issues with my code and wondering if anything jumps out. 1. every time...