[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming resolved KAFKA-12701.
Assignee: Justine Olshan (was: dengziming)
Resolution: Fixed
> NPE in MetadataRequest when
[
https://issues.apache.org/jira/browse/KAFKA-13222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Liu updated KAFKA-13222:
Priority: Major (was: Minor)
> Records in newly rolled segment couldn't be fetched by consumer
>
Zhipeng Liu created KAFKA-13222:
---
Summary: Records in newly rolled segment couldn't be fetched by
consumer
Key: KAFKA-13222
URL: https://issues.apache.org/jira/browse/KAFKA-13222
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402624#comment-17402624
]
Tomer Wizman commented on KAFKA-12766:
--
Hi Bruno, Sophie, Konstantine, nice e-meeti
rondagostino commented on pull request #11239:
URL: https://github.com/apache/kafka/pull/11239#issuecomment-903126406
Thanks, @ijuma. Yeah, the problem was that there were two different ways to
get at a state -- only one of which was working -- and it makes sense to
eliminate `currentStat
PhilHardwick commented on pull request #11248:
URL: https://github.com/apache/kafka/pull/11248#issuecomment-903093642
Requesting review from @ableegoldman and @wcarlson5 please
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
PhilHardwick opened a new pull request #11248:
URL: https://github.com/apache/kafka/pull/11248
The alive stream threads metric relies on the threads field as a monitor
object for
its synchronized block. When the alive stream threads metric is registered
it isn't
initialised so any ca
showuon commented on a change in pull request #11225:
URL: https://github.com/apache/kafka/pull/11225#discussion_r693322503
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1436,17 +1438,15 @@ class ReplicaManager(val config: KafkaConfig,