MaximGurschi
MaximGurschi
@pennello Having the same issue, and can confirm your workaround works.
Looks like KF type consumers offsets are lost if you restart KafkaManager or if the consumer starts consuming before Kafka Manager is up. See if checking "Enable Active OffsetCache (Not...
@KaimingWan You are correct that suggestion fix was a false positive. I am still not aware of how to always have the consumers show up. The only regularity i have...
@ialejandro Do you manage to see anything in "consumer" tab when plugin with Kafka 2.8.0?
@JoshuaBunag After some messing about CMAK 3.0.0.5 does actually display the consumer tab info using Kafka 2.8.0. I did not have to do anything special.
Good idea to create a separate issue. Is the producer going to wait for outstanding requests to be transmitted and handled? I am not sure RdKafka.Handle.Dispose gets called during finalizations....
If i modify the sample above to keep references to the topic and producers and Disposing them after the outer loop (i accumulate two lists) then the application does not...
The other thing, is that i cannot reproduce the crash if i do not call Produce in Parallel. Correction - just done that now. See next post.
If i add some logging to SafeTopicHandle.ReleaseHandle and SafeKafkaHandle.ReleaseHandle and actually run everything single threaded (so in the above sample code, replace Parallel.For(0, Count, _ => topic.Produce(null)) with for (var...
Notice how there is no matching "19 ExitReleaseHandle.SafeTopicHandle" and "20 Exit.ReleaseHandle.Producer"