kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax" <matth...@confluent.io>
Subject Re: [DISCUSS] KIP-247: Add public test utils for Kafka Streams
Date Wed, 17 Jan 2018 02:34:17 GMT

the TopologyTestDriver does not connect to any broker and simulates
processing of single-partitioned input topics purely in-memory (the
driver is basically a mock for a StreamThread). This is sufficient to
test basic business logic. For more complex topologies that are actually
divided into sub-topologies and connected via topics, the driver detects
this case and does an in-memory forward.


On 1/16/18 10:08 AM, Colin McCabe wrote:
> Thanks, Matthias, this looks great.
> It seems like these APIs could either be used against mock objects, or against real brokers
running in the same process.  Is there a way for the user to select which they want when using
the API?  Sorry if it's in the KIP and I missed it.
> cheers,
> Colin
> On Thu, Jan 11, 2018, at 18:06, Matthias J. Sax wrote:
>> Dear Kafka community,
>> I want to propose KIP-247 to add public test utils to the Streams API.
>> The goal is to simplify testing of Kafka Streams applications.
>> Please find details in the wiki:
>> https://cwiki.apache.org/confluence/display/KAFKA/KIP-247%3A+Add+public+test+utils+for+Kafka+Streams
>> This is an initial KIP, and we hope to add more utility functions later.
>> Thus, this KIP is not comprehensive but a first step. Of course, we can
>> enrich this initial KIP if we think it falls too short. But we should
>> not aim to be comprehensive to keep the scope manageable.
>> In fact, I think we should add some more helpers to simplify result
>> verification. I will update the KIP with this asap. Just wanted to start
>> the discussion early on.
>> An initial WIP PR can be found here:
>> https://github.com/apache/kafka/pull/4402
>> I also included the user-list (please hit "reply-all" to include both
>> lists in this KIP discussion).
>> Thanks a lot.
>> -Matthias
>> Email had 1 attachment:
>> + signature.asc
>>   1k (application/pgp-signature)

View raw message