You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
A windowed table such as the one below is not created with the compacted topic cleanup policy.
CREATETABLEbarASSELECTcount(*) as count, id
FROM foo
WINDOW SESSION (1 hour)
GROUP BY id;
To Reproduce
Create the stream above based on:
CREATE STREAM bar ASSELECTcount(*) as count, id FROM foo WINDOW SESSION (1 hour) GROUP BY id;
List the configs of the topic:
(13:11:06) confluent-5.5.1-SNAPSHOT ➤ ./bin/kafka-configs --topic BAR --bootstrap-server localhost:29092 --describe --all
All configs for topic BAR are:
...
{DEFAULT_CONFIG:log.cleanup.policy=delete}
...
Expected behavior
The topic should use cleanup.policy=[compact,delete]
Actual behaviour
The topic uses cleanup.policy=[delete]
Additional context
There are two workarounds:
we can create the topic before issuing the create statement
we can alter the topic using kafka-configs to change the cleanup policy:
Describe the bug
A windowed table such as the one below is not created with the
compacted
topic cleanup policy.To Reproduce
Create the stream above based on:
List the configs of the topic:
(13:11:06) confluent-5.5.1-SNAPSHOT ➤ ./bin/kafka-configs --topic BAR --bootstrap-server localhost:29092 --describe --all All configs for topic BAR are: ... {DEFAULT_CONFIG:log.cleanup.policy=delete} ...
Expected behavior
The topic should use
cleanup.policy=[compact,delete]
Actual behaviour
The topic uses
cleanup.policy=[delete]
Additional context
There are two workarounds:
kafka-configs
to change the cleanup policy:It seems like this was called out by @rodesai here: #1042 (comment) but it was not addressed
The text was updated successfully, but these errors were encountered: