You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Alan Kash <cr...@gmail.com> on 2016/11/27 02:27:43 UTC

Interactive Queries

Hi,

New to Kafka land.

I am looking into Interactive queries feature, which transforms Topics into
Tables with history, neat !

1. What kind of queries we can run on the store ?  Point or Range ?
2. Is Indexing supported ? primary or seconday ?
3. Query language - SQL ? Custom Java Native Query ?

I see rocksdb is the persistent layer.

Did the team look at JCache API (JSR 107) -
https://jcp.org/en/jsr/detail?id=107 ?

Thanks,
Alan

Re: Interactive Queries

Posted by Alan Kash <cr...@gmail.com>.

Thanks All.

On Mon, Nov 28, 2016 at 3:09 AM, Michael Noll <mi...@confluent.io> wrote:

> There are also some examples/demo applications at
> https://github.com/confluentinc/examples that demonstrate the use of
> interactive queries:
>
> -
> https://github.com/confluentinc/examples/blob/3.
> 1.x/kafka-streams/src/main/java/io/confluent/examples/
> streams/interactivequeries/kafkamusic/KafkaMusicExample.java
>
> -
> https://github.com/confluentinc/examples/blob/3.
> 1.x/kafka-streams/src/main/java/io/confluent/examples/
> streams/interactivequeries/WordCountInteractiveQueriesExample.java
>
> Note: The `3.1.x` branch is for Kafka 0.10.1.
>
> -Michael
>
>
>
>
> On Sun, Nov 27, 2016 at 3:35 AM, David Garcia <da...@spiceworks.com>
> wrote:
>
> > I would start here: http://docs.confluent.io/3.1.0/streams/index.html
> >
> >
> > On 11/26/16, 8:27 PM, "Alan Kash" <cr...@gmail.com> wrote:
> >
> >     Hi,
> >
> >     New to Kafka land.
> >
> >     I am looking into Interactive queries feature, which transforms
> Topics
> > into
> >     Tables with history, neat !
> >
> >     1. What kind of queries we can run on the store ?  Point or Range ?
> >     2. Is Indexing supported ? primary or seconday ?
> >     3. Query language - SQL ? Custom Java Native Query ?
> >
> >     I see rocksdb is the persistent layer.
> >
> >     Did the team look at JCache API (JSR 107) -
> >     https://jcp.org/en/jsr/detail?id=107 ?
> >
> >     Thanks,
> >     Alan
> >
> >
> >
>

Re: Interactive Queries

Posted by Michael Noll <mi...@confluent.io>.

There are also some examples/demo applications at
https://github.com/confluentinc/examples that demonstrate the use of
interactive queries:

-
https://github.com/confluentinc/examples/blob/3.1.x/kafka-streams/src/main/java/io/confluent/examples/streams/interactivequeries/kafkamusic/KafkaMusicExample.java

-
https://github.com/confluentinc/examples/blob/3.1.x/kafka-streams/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesExample.java

Note: The `3.1.x` branch is for Kafka 0.10.1.

-Michael




On Sun, Nov 27, 2016 at 3:35 AM, David Garcia <da...@spiceworks.com> wrote:

> I would start here: http://docs.confluent.io/3.1.0/streams/index.html
>
>
> On 11/26/16, 8:27 PM, "Alan Kash" <cr...@gmail.com> wrote:
>
>     Hi,
>
>     New to Kafka land.
>
>     I am looking into Interactive queries feature, which transforms Topics
> into
>     Tables with history, neat !
>
>     1. What kind of queries we can run on the store ?  Point or Range ?
>     2. Is Indexing supported ? primary or seconday ?
>     3. Query language - SQL ? Custom Java Native Query ?
>
>     I see rocksdb is the persistent layer.
>
>     Did the team look at JCache API (JSR 107) -
>     https://jcp.org/en/jsr/detail?id=107 ?
>
>     Thanks,
>     Alan
>
>
>

Re: Interactive Queries

Posted by David Garcia <da...@spiceworks.com>.

I would start here: http://docs.confluent.io/3.1.0/streams/index.html


On 11/26/16, 8:27 PM, "Alan Kash" <cr...@gmail.com> wrote:

    Hi,
    
    New to Kafka land.
    
    I am looking into Interactive queries feature, which transforms Topics into
    Tables with history, neat !
    
    1. What kind of queries we can run on the store ?  Point or Range ?
    2. Is Indexing supported ? primary or seconday ?
    3. Query language - SQL ? Custom Java Native Query ?
    
    I see rocksdb is the persistent layer.
    
    Did the team look at JCache API (JSR 107) -
    https://jcp.org/en/jsr/detail?id=107 ?
    
    Thanks,
    Alan