Francois Poinsot

One thing that prevented me to use Sarama as a basis for some tools is the lack of support for transactions. Having transactions would allow doing operations using only Kafka,...

I am not quite sure I understand what is blocking you from setting the status code. Is it that you want to create the span first but only set the...

I know it is a bit late but let's see if we can solve this. I am not quite sure i understand. Can you provide a reproducible scenario ?

I am facing the same issue. I have realised that I always get 16 Reconciler errors "Stage health evaluated to Unknown". Looked into the default backoff strategy of runtime controller....

To test my theory I made this change in the controller configuration ``` import( "k8s.io/client-go/util/workqueue" "sigs.k8s.io/controller-runtime/pkg/reconcile" ) func CommonOptions(maxConcurrentReconciles int) controller.Options { return controller.Options{ [...] RateLimiter: workqueue.NewTypedItemExponentialFailureRateLimiter[reconcile.Request](5*time.Millisecond, 10*time.Second), } }...

To add to this, here are logs for 1 promotion for 1 shard controller. The way the errors are packed early is what does not make sense to me. It...

a concrete example of the problem I am facing is with the emissary-ingress CRD from v1 and v2 schema. They had to update these CRD to support the rule introduced...