You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Describe the bug KafkaTopicManager will registers a producer in PersistentTopic every time KafkaTopicManager#getTopic invoked.
However KafkaTopicManager#getTopic is invoked from not only ProduceRequest, but also many other places like KafkaRequestHandler#finkBroker() or KafkaRequestHandler#handleListOffsetRequestV1AndAbove etc.
Expected behavior
Kop should register producer only when the request is ProduceRequest
Describe the bug
KafkaTopicManagerwill registers a producer inPersistentTopicevery timeKafkaTopicManager#getTopicinvoked.However
KafkaTopicManager#getTopicis invoked from not onlyProduceRequest, but also many other places likeKafkaRequestHandler#finkBroker()orKafkaRequestHandler#handleListOffsetRequestV1AndAboveetc.Expected behavior
Kop should register producer only when the request is
ProduceRequest