If your data is already partitioned by key, you can save writing to a topic by doing a dummy reduce instead:
stream
.groupByKey()
.reduce(new Reducer() {
V apply(V value1, V value2) {
return value2;
}
},
"yourStoreName");
(replace V with your actuall value type)
-Matthias
On 1/24/17 8:53 AM, Damian Guy wrote:
> Hi Nick,
>
> I guess there is some reason why you can't just build it as a table to
> begin with?
> There isn't a convenient method for doing this right now, but you could do
> something like:
>
> stream.to("some-other-topic");
> builder.table("some-other-topic");
>
> Thanks,
> Damian
>
> On Tue, 24 Jan 2017 at 16:32 Nick DeCoursin <n.decour...@foodpanda.com>
> wrote:
>
>> Hello,
>>
>> How can I simply table a Kafka Stream? I have a Kafka Stream, and I want to
>> create a table from it backed by a state store. The key of the stream could
>> be the same as the table.
>>
>> I've tried following examples, but it seems all examples use `groupBy` or
>> `count` to convert `KStream`s into `KTable`s. Is there any other way?
>>
>> Thank you very much,
>> Nick DeCoursin
>>
>> --
>>
>> Nick DeCoursin
>> Software Engineer
>> foodpanda
>>
>> Tel | +1 920 450 5434 <(920)%20450-5434>
>>
>> Mail | n.decour...@foodpanda.com
>>
>> Skype | nick.foodpanda
>>
>> Foodpanda GmbH | Schreiberhauer Str. 30 | 10317 Berlin | Germany
>> Sitz der Gesellschaft | Berlin, AG Charlottenburg | HRB 138224 B |
>> USt-ID-Nr | DE 283789080
>> Geschäftsführer | Benjamin Bauer, Felix Plog, Ralf Wenzel
>>
>> CONFIDENTIALITY NOTICE: This message (including any attachments) is
>> confidential and may be privileged. It may be read, copied and used only by
>> the intended recipient. If you have received it in error please contact the
>> sender (by return e-mail) immediately and delete this message. Any
>> unauthorized use or dissemination of this message in whole or in parts is
>> strictly prohibited.
>>
>
signature.asc
Description: OpenPGP digital signature
