Hello, Good video, But on a enterprise level, we dont want avro schema to defined initially , we want the incoming xml files to be dynamically converted to avro schemas and pushed to the topic. Please provide your inputs on this , how do we do this
Kafka does not understand xml language, you have to convert xml into avro object. You can search finding any tool to convert xml schema into avro schema
nice video, just have a question how can we map the complex request body to the Avro schema file. Coz we can't set the field one by one in this case. Thanks
@@javatechlearning thanks, please i have another question, How can i connect to My eventhub service to get the registry schema? Or How is the producer configuration?
Great... Nicely explained 👌
You made it sooo simple. Thanks!
Simply Awesome..!!👏👍👏👍
Thanks for posting such useful content. Much appreciated. Thanks.
Thanks for your feedback
Good one, got basic idea and nice explanation.
Thank you so much
Thank you for your feedback 😊
Awesome explanation and very helpful.👍
Thanku for your kind words
too good sir! thanks you soo much, you are life savior!
very very helpful sir, thank you very much
Thanks 🙏
Thanks for this useful tutorial.
Thanku for your feedback
can I use same commands to apache kafka?
Thanks Vishal. How a connector gets acks that message is received which is possible through client api java code.
Great video!
Hello,
Good video, But on a enterprise level, we dont want avro schema to defined initially , we want the incoming xml files to be dynamically converted to avro schemas and pushed to the topic. Please provide your inputs on this , how do we do this
Kafka does not understand xml language, you have to convert xml into avro object. You can search finding any tool to convert xml schema into avro schema
@@javatechlearning can I use kafka connect or pls suggest me what’s your best bet
I think there is some file connector also present in confluent. Try exploring that
nice video, just have a question how can we map the complex request body to the Avro schema file. Coz we can't set the field one by one in this case. Thanks
Either you can use avro schema object itself in request body or using constructor based builder method in avro class
You can use mapstruct library to convert your DTO's to entity or any other schema for that matter.
how do you define the source and output directories in a gradle project that uses build.gradle?
Good tutorial. Curious why you didn't use the builder to initialize the Stock history model though 🤣🤣
Awesome explination. Could you please provide same code.
Can you please share how we can generate java file in gradle project for avsc
can u please tell , how can i get the address of this bootstrap-servers ? and this registry: url: ?
Bootstrap sever is broker which I installed on my local machine
@@javatechlearning ok so how can i check the url and address for that .
Source code is not available on the github repo you have provided in the video description
Source code checked in now. Sorry for inconvenience
But where we used schema registry? We haven't used anywhere
We used schema registry. Its not possible to produce avro on topic without schema registry
Super explanation bro.
One query..I have Java complex pojo. How to generate pojo to avro schema.can you help on this
i have the same question
Let me do some research on it. Will get back to you. Thanks
@@javatechlearning thanks, please i have another question, How can i connect to My eventhub service to get the registry schema? Or How is the producer configuration?
Error Registering Avro Schema I am getting this error. BTW I am running kafka on a docker image on my local
Check if you're schema registry is working or not
Are you able to connect schema registry?