kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Marina Popova <ppin...@protonmail.com.INVALID>
Subject Re: SELECT * from table shows no data until new messages come in
Date Mon, 06 May 2019 20:51:06 GMT
Thank you , Steve, for the suggestion - I did already set this property to earliest:
Just to make sure - I set it again - below is the output from the CLI:

ksql> SET 'auto.offset.reset' = 'earliest';

Successfully changed local property 'auto.offset.reset' from 'earliest' to 'earliest'.

ksql> select * from RC_IP_KEY_AGG_PTABLE;


Press CTRL-C to interrupt

As you see above - to results are returned from the table ....
Only after I send a few more events - I will get something as results.....



Sent with [ProtonMail](https://protonmail.com) Secure Email.

‐‐‐‐‐‐‐ Original Message ‐‐‐‐‐‐‐
On Monday, May 6, 2019 4:44 PM, Steve Howard <steve.howard@confluent.io> wrote:

> 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>
>>> 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
>>> GROUP BY remote_addr;
>>> I verified that the Stream "rc_events_full" gets events OK from its underlying
>>> 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
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message