root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

KAFKA-15215: migrate StreamedJoinTest to Mockito (#15424) 

Migrate StreamedJoinTest to Mockito

Reviewers: Anna Sophie Blee-Goldman <ableegoldman@apache.org>, 
Divij Vaidya <diviv@amazon.com>
This commit is contained in:
Almog Gavra 2024-02-26 18:52:25 -08:00 committed by GitHub
parent ddfcc333f8
commit 1c9f360f4a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
build.gradle
View File

@ -2333,6 +2333,8 @@ project(':streams:streams-scala') {
testImplementation libs.junitJupiter
testImplementation libs.easymock
testImplementation libs.mockitoCore
testImplementation libs.mockitoJunitJupiter // supports MockitoExtension
testImplementation libs.hamcrest
testRuntimeOnly libs.slf4jlog4j
}

18
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/StreamJoinedTest.scala
View File

@ -21,24 +21,26 @@ import org.apache.kafka.streams.processor.internals.InternalTopologyBuilder
import org.apache.kafka.streams.scala.serialization.Serdes
import org.apache.kafka.streams.scala.serialization.Serdes._
import org.apache.kafka.streams.state.Stores
import org.easymock.EasyMock
import org.easymock.EasyMock.{createMock, replay}
import org.junit.jupiter.api.Assertions.assertEquals
import org.junit.jupiter.api.extension.ExtendWith
import org.junit.jupiter.api.{BeforeEach, Test}
import org.mockito.Mockito.{mock, when}
import org.mockito.junit.jupiter.{MockitoExtension, MockitoSettings}
import org.mockito.quality.Strictness
import java.time.Duration
@ExtendWith(Array(classOf[MockitoExtension]))
@MockitoSettings(strictness = Strictness.STRICT_STUBS)
class StreamJoinedTest {
val builder: InternalStreamsBuilder = createMock(classOf[InternalStreamsBuilder])
val topoBuilder: InternalTopologyBuilder = createMock(classOf[InternalTopologyBuilder])
val builder: InternalStreamsBuilder = mock(classOf[InternalStreamsBuilder])
val topoBuilder: InternalTopologyBuilder = mock(classOf[InternalTopologyBuilder])
@BeforeEach
def before(): Unit = {
EasyMock.expect(builder.internalTopologyBuilder()).andReturn(topoBuilder);
EasyMock.expect(topoBuilder.topologyConfigs()).andReturn(null)
replay(topoBuilder)
replay(builder)
when(builder.internalTopologyBuilder()).thenReturn(topoBuilder)
when(topoBuilder.topologyConfigs()).thenReturn(null)
}
@Test