Notify producers/consumers on schema changes

[muralibasani]

What is currently missing?

When a new version of schema is uploaded on a topic, producers and consumers should be notified

How could this be improved?

Notifications should be sent when schema changes are done on a topic to all acl owners.

Is this a feature you would work on yourself?

• I plan to open a pull request for this feature

[Sadaf-A]

Greetings @muralibasani, I would like to work on this could you please link the GitHub file. It would make it a lot easier for me!

[dipeshsingh253]

Hey @muralibasani , I would like to work on this issue. If it's still available.

[muralibasani]

@dipeshsingh253 please go ahead, as you are a new contributor.

@Sadaf-A you might want to review the PR from this.

[Sadaf-A]

@dipeshsingh253 please go ahead, as you are a new contributor.

@Sadaf-A you might want to review the PR from this.

hey, I hope you are well. did you mean yo say I should review the PR? just wanted to confirm.

[muralibasani]

@Sadaf-A let's wait until the PR has been submitted and you can review it. thanks.

[dipeshsingh253]

Hey @muralibasani Thanks for the opportunity.

Also thanks @Sadaf-A , I will let you know once I'm done with the issue.

Thanks for your patience 😊.

[dipeshsingh253]

Hey @muralibasani, I was trying to replicate this issue in my local but I am not able to access the clusterapi-webportal in my local.
I am getting this error :

2023-10-06T05:29:50.995+05:30  INFO 13653 --- [           main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat started on port(s): 9343 (http) with context path ''
2023-10-06T05:29:51.032+05:30  INFO 13653 --- [           main] i.a.k.c.KafkaClusterApiApplication       : Started KafkaClusterApiApplication in 4.383 seconds (process running for 5.334)
2023-10-06T05:29:57.341+05:30  INFO 13653 --- [nio-9343-exec-1] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring DispatcherServlet 'dispatcherServlet'
2023-10-06T05:29:57.342+05:30  INFO 13653 --- [nio-9343-exec-1] o.s.web.servlet.DispatcherServlet        : Initializing Servlet 'dispatcherServlet'
2023-10-06T05:29:57.345+05:30  INFO 13653 --- [nio-9343-exec-1] o.s.web.servlet.DispatcherServlet        : Completed initialization in 2 ms
2023-10-06T05:29:57.382+05:30  WARN 13653 --- [nio-9343-exec-1] i.a.k.c.config.JwtRequestFilter          : JWT Token does not begin with Bearer String
2023-10-06T05:30:40.499+05:30  WARN 13653 --- [nio-9343-exec-2] i.a.k.c.config.JwtRequestFilter          : JWT Token does not begin with Bearer String

I followed this to run Klaw in local : https://www.klaw-project.io/docs/HowTo/installation/run-source

Thanks for your time !!!

[Sadaf-A]

Hey @muralibasani, I was trying to replicate this issue in my local but I am not able to access the clusterapi-webportal in my local.
I am getting this error :

2023-10-06T05:29:50.995+05:30  INFO 13653 --- [           main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat started on port(s): 9343 (http) with context path ''
2023-10-06T05:29:51.032+05:30  INFO 13653 --- [           main] i.a.k.c.KafkaClusterApiApplication       : Started KafkaClusterApiApplication in 4.383 seconds (process running for 5.334)
2023-10-06T05:29:57.341+05:30  INFO 13653 --- [nio-9343-exec-1] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring DispatcherServlet 'dispatcherServlet'
2023-10-06T05:29:57.342+05:30  INFO 13653 --- [nio-9343-exec-1] o.s.web.servlet.DispatcherServlet        : Initializing Servlet 'dispatcherServlet'
2023-10-06T05:29:57.345+05:30  INFO 13653 --- [nio-9343-exec-1] o.s.web.servlet.DispatcherServlet        : Completed initialization in 2 ms
2023-10-06T05:29:57.382+05:30  WARN 13653 --- [nio-9343-exec-1] i.a.k.c.config.JwtRequestFilter          : JWT Token does not begin with Bearer String
2023-10-06T05:30:40.499+05:30  WARN 13653 --- [nio-9343-exec-2] i.a.k.c.config.JwtRequestFilter          : JWT Token does not begin with Bearer String

I followed this to run Klaw in local : https://www.klaw-project.io/docs/HowTo/installation/run-source

Thanks for your time !!!

Hello @dipeshsingh253 ,

I kindly request that you format your token as follows:

Bearer ${token}

So, it should be a string that looks like "Bearer <your_token>"

Your attention to this matter is greatly appreciated.

[dipeshsingh253]

Hello @Sadaf-A , I am using a browser to access the web portal. and also in the , there is no mention of how to get the token for the first time.

Can you please elaborate more on this? It will be very helpful.

Thanks ☺️

[muralibasani]

@Sadaf-A @dipeshsingh253
Klaw cluster api doesn't have a web portal. Only core module has a web portal. And by default it runs at port 9097.
http://localhost:9097

For the token part, in cluster api properties, property klaw.clusterapi.access.base64.secret there is an example token above. You can use the same and copy that token to core module application properties too.

[dipeshsingh253]

Hi @muralibasani @Sadaf-A ,

I've successfully run and logged into the Klaw UI in my local environment. However, I have faced some difficulties while trying to create a Kafka cluster:

What should be filled in the "rest API server" field in the Kafka cluster creation form?

If there are any how-to guides or documentation available for setting up Klaw locally for development purposes, please share them with me.

I'm curious if there's a Klaw community on Discord or Zulip where I can seek assistance. I couldn't find any links to these platforms and currently, this issue is my sole means of communication.

Thank you!

[muralibasani]

@dipeshsingh253
https://aiven.io/community/forum/tag/klaw is klaw community

Reg adding cluster, restapiserver is optional field there. Docs : https://www.klaw-project.io/docs/HowTo/clusterconnectivity/kafka-cluster-ssl-protocol

what is your mail id ? I can send a slack invite.

[dipeshsingh253]

Thanks @muralibasani , and sure here is my email : [email protected]