C
C#•2y ago
atakancracker

❔ Kafka Producer Timeouts And How To Detect Undelivered Messages

I am using confluent-kafka package for my producer, recently we run load test to kafka connector via our web api. Noticed after a while in total we send 10m requests but only 8.5m messages received by kafka broker. How can I detect why those messages are not produced ? I am suspecting about timeout configuration on producer
2 Replies
atakancracker
atakancracker•2y ago
request.timeout.ms is the timeout configured on the client side. It says that the client is going to wait this much time for the server to respond to a request. If request.timeout.ms set to 30 seconds and kafka broker not respond to producer within 30 seconds. That message is lost and not delivered to leader. Am I correct ?
Accord
Accord•2y ago
Looks like nothing has happened here. I will mark this as stale and this post will be archived until there is new activity.
Want results from more Discord servers?
Add your server
More Posts
❔ Implement Angular in existing ASP.NET Core MVC project?Hi, I have an ASP.NET MVC web app that takes a file upload in and produces an output. It uses Razor❔ [SOLVED] Visual Studio for macOS Ventura bugI am facing an issue with the latest version of macOS ie. Ventura 13.0.1 and Visual Studio. My toolt❔ JWT with Identity issueHi friends, I'm working on a simple `ASP.NET Core 7` project, with `Identity` and `EF Core`, `JWT` ❔ how to pass multiple arguments in apicall from ajex get url?i used following approach already❔ maui is it possible that we can get all the pages that registered to the shell ?Hi my project currently using Shell.Current.GotoAsync(“url”) to navigate to the destination I want, ❔ Replace multiple LinesWhat I had before was ```C# string SessionName = File.ReadAllText(ConfigFile); Session❔ how to run the asp .netcore backendI already set up the react and .netcore environment but i can not start the server side. Can someoneASP.NET Core | Issue with in-memory data removalHey there, I am currently trying to make a backend service for my chess game made in Next.js as an i