KSQL CLI "SET 'ksql.streams.retention.ms' = '86400000';" command broken?

[oflasch]

The KSQL FAQ contains an example of setting the message retention of KSQL-created topics ( https://docs.confluent.io/current/ksql/docs/faq.html#how-do-i-set-the-retention-period-for-streams-created-for-ksql-queries ).

With KSQL version 5.1.0, this does not seem to work anymore:

ksql> SET 'ksql.streams.retention.ms' = '86400000';
Not recognizable as ksql, streams, consumer, or producer property: 'ksql.streams.retention.ms'

Am I missing something?

Many thanks in advance.

[apurvam]

cc @big-andy-coates @rodesai . Did the new config system break this config? What is the correct version?

[the4thamigo-uk]

Any news on this?

[eggspertt]

Getting the same response on version 5.1.0 from the CLI and using the rest api to set the value: { "@type": "generic_error", "error_code": 50000, "message": "Failed to set 'ksql.streams.retention.ms' to '14400000'\nCaused by: Not recognizable as ksql, streams, consumer, or producer property: 'ksql.streams.retention.ms'", "stackTrace": [ "io.confluent.ksql.rest.entity.KsqlRequest.coerceType(KsqlRequest.java:91)", "io.confluent.ksql.rest.entity.KsqlRequest.lambda$coerceTypes$0(KsqlRequest.java:82)", "java.util.HashMap.forEach(HashMap.java:1289)", "java.util.Collections$UnmodifiableMap.forEach(Collections.java:1505)", "io.confluent.ksql.rest.entity.KsqlRequest.coerceTypes(KsqlRequest.java:82)", "io.confluent.ksql.rest.entity.KsqlRequest.getStreamsProperties(KsqlRequest.java:53)", "io.confluent.ksql.rest.server.resources.KsqlResource.handleKsqlStatements(KsqlResource.java:174)", "sun.reflect.GeneratedMethodAccessor69.invoke(Unknown Source)", "sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)", "java.lang.reflect.Method.invoke(Method.java:498)", "org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory.lambda$static$0(ResourceMethodInvocationHandlerFactory.java:76)", "org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher$1.run(AbstractJavaResourceMethodDispatcher.java:148)", "org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.invoke(AbstractJavaResourceMethodDispatcher.java:191)", "org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$ResponseOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:200)", "org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:103)", "org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:493)", "org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:415)", "org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:104)", "org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:277)", "org.glassfish.jersey.internal.Errors$1.call(Errors.java:272)", "org.glassfish.jersey.internal.Errors$1.call(Errors.java:268)", "org.glassfish.jersey.internal.Errors.process(Errors.java:316)", "org.glassfish.jersey.internal.Errors.process(Errors.java:298)", "org.glassfish.jersey.internal.Errors.process(Errors.java:268)", "org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:289)", "org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:256)", "org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:703)", "org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:416)", "org.glassfish.jersey.servlet.ServletContainer.serviceImpl(ServletContainer.java:409)", "org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:584)", "org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:525)", "org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:462)", "org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1642)", "org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:533)", "org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:255)", "org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1595)", "org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:255)", "org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1340)", "org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:203)", "org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:473)", "org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1564)", "org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:201)", "org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1242)", "org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:144)", "org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:126)", "org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:174)", "org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:220)", "org.eclipse.jetty.server.handler.gzip.GzipHandler.handle(GzipHandler.java:740)", "org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:132)", "org.eclipse.jetty.server.Server.handle(Server.java:503)", "org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:364)", "org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:260)", "org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:305)", "org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:103)", "org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:118)", "org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:765)", "org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:683)", "java.lang.Thread.run(Thread.java:748)" ] }