kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Steve Howard <steve.how...@confluent.io>
Subject Re: SELECT * from table shows no data until new messages come in
Date Mon, 06 May 2019 20:44:50 GMT
Sorry, I hit send too quickly.

On Mon, May 6, 2019 at 4:42 PM Steve Howard <steve.howard@confluent.io>
wrote:

> Hi Marina,
>
> Try...
>
> set 'auto.offset.reset'='earliest';
>
>
> Thanks,
>
>
> Steve
>
> On Mon, May 6, 2019 at 4:40 PM Marina Popova
> <ppine7p@protonmail.com.invalid> wrote:
>
>> Hi,
>> Trying to understand if I'm missing something...
>> I'm using Confluent KSQL setup (running all components in Docker
>> containers). I've created a Table from a Stream, as following:
>>
>> CREATE TABLE rc_ip_key_agg_ptable AS
>> SELECT remote_addr,
>>       windowStart(),
>>       windowEnd(),
>>       count(*)
>> FROM rc_events_full
>> WINDOW TUMBLING (SIZE 30 SECONDS)
>> GROUP BY remote_addr;
>>
>> I verified that the Stream "rc_events_full" gets events OK from its
>> underlying topic.
>> I did "ksql> SET 'auto.offset.reset' = 'earliest';"
>>
>> When I try to select results from the table as:
>> "select * from rc_ip_key_agg_ptable;"
>>
>> I do not see any results;
>>
>> When I send a few new events to the topic/stream - I do see the
>> aggregated results from the table - and the results are aggregated for ALL
>> events that has been send so far, not just the latest few I just sent,
>> which confirms that the table is indeed persisted and the state is
>> correctly accumulated.
>>
>> I understand it is a continuous query, and I will see newly aggregated
>> results after each new event comes.
>> However, I thought that when I start/run the "select * from
>> rc_ip_key_agg_ptable;" - I would see the latest state from the table,
>> whatever was aggregated so far.
>> Does not seem to be the case for me - I only see the result after new
>> events woudl come , AFTER I start the query ....
>>
>> Am I missing some configuration setting?
>>
>> Thank you!
>> Marina
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message