Skip to content

A minimal example of a problem unit testing a Kafka Streams processor

Notifications You must be signed in to change notification settings

fetherolfjd/kafka-streams-proc-unit-test

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

1 Commit
 
 
 
 
 
 
 
 

Repository files navigation

Kafka Stream Unit Testing Failure

This repo is a minimal example to reproduce an error when attempting to unit test a processor with an InMemoryWindowStore which is leading to a ClassCastException when it attempts to cast a MockProcessorContext to an InternalProcessorContext.

mvn --version outputs:

Apache Maven 3.5.0 (ff8f5e7444045639af65f6095c62210b5713f426; 2017-04-03T13:39:06-06:00)
Maven home: ~/opt/apache-maven-3.5.0
Java version: 1.8.0_212, vendor: Oracle Corporation
Java home: /usr/lib/jvm/java-8-openjdk-amd64/jre
Default locale: en_US, platform encoding: UTF-8
OS name: "linux", version: "4.15.0-52-generic", arch: "amd64", family: "unix"

About

A minimal example of a problem unit testing a Kafka Streams processor

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages