cmccabe commented on code in PR #13140:
URL: https://github.com/apache/kafka/pull/13140#discussion_r1083122187
##########
core/src/test/scala/unit/kafka/raft/RaftManagerTest.scala:
##########
@@ -221,16 +225,23 @@ class RaftManagerTest {
@Test
def testUncaughtExceptionInIoThread(): Unit = {
val raftClient = mock(classOf[KafkaRaftClient[String]])
- val ioThread = new RaftIoThread(raftClient, threadNamePrefix = "test-raft")
+ val faultHandler = mock(classOf[FaultHandler])
Review Comment:
easier to just use `MockFaultHandler`
you can then look at `MockFaultHandler.firstException` to at least see if it
has the `Unexpected error in raft IO thread` text
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
