วีดีโอ

Most sensible video on Kafka topic, thank you very much.

I really appreciate this brief and well delivered tutorial. Thanks. However, I am wondering why you would use POST as you are retrieving departments. Would appreciate knowing. I would have thought it would still be a GET.

You made it sooo simple. Thanks!

Hi, do you have any example of how to configure in a project the Confluent Control Center? I couldn't find an example

Hi, can you please confirm 1)why you are using Avro converter? If I didn't set any schema for the topic means what should I give here? 2)pk.mode and pk.fields is mandatory?

If we want to extract header json into the db table columns how can this be done ?

Very good content!! Thank you very much for creating this!! 💯👌

Really very useful video ❤thank you very much !

I have a question... let's say we have in the store "DENIM" - 7 "SHIRTS" - 5 If I receive a tombstone for one of them, will the KTable manage and reduce the related long after grouping by? Actually not... I created a test with TestTopologyDriver and I sent three key/value pairs, then for the first key I am sending tombstone value and guess what? KTable returned me all the three values related to the keys and the tombstone was ignored. If you go to aggregate() operation you will see that it is skipping null value entries and I am wondering how we can manage our store, because it will only grow by the time, right?

This is Really Helpful. Please keep us posted more. Thaks a lot. By any chance do you take classes? Let me know. I am interested.

Really Good one but I got one question For example I am writing only Cosumer and how I Know StockHistory and where I need to keep . I mean to how exact package structer need to be set @ Consumer

very nice content, congratulations and thank you so much. Keep up the good work!

alternate for avro? if possible provide any example for that also. Thanks

First view

Thank You, Please Continue on new topics of Programming

Cheers bro!

How to insert this type of day { "_id": { "string": "663ba280e41f1aa25e72f32a" }, "Address": { "array": [ { "string": "a" }, { "string": "b" }, { "string": "c" } ] }, "City": { "string": "Norway" }, "FirstName": { "string": "Tom" }, "LastName": { "string": "Cardinal" }, "PersonID": { "int": 1 } }

Link to source code please?

💯👏👏👏👏

Can we do this same in using spring boot

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

Hi vishal can you share gradle project dependencies for creating target folder for avro schema

Can you please share how we can generate java file in gradle project for avsc

You must continue your teaching bro. You are excellent thanks

@javatechlearning : source code missing

@javatechlearning : Can you checkin code for stateful operations?

Hi Sir, am not able to see skip payment option. What should i do. Please tell me ?

Would this work with any RDBMS? Would it work with Sybase ASE as the sink?

How can I use the values I received after the http call and assign it to a variable

Hi, I could not see the source code of this tutorial in the given Github repo. Can you please add?

how does adf authenticates with mulesoft and how mulesoft authenticates with api sources how adf triggers mulesoft workflow after mulesoft is published to cloud hub?

Thanks for quick video. This is helpful.

Bro.. Any videos you can refer me to as on how do we leverage Confluent in Data Engineering? I know Kafka in and out, just not Confluent in practice

'buildStreamsProperties()' is deprecated and marked for removal. edit: this worked for me instead: @Bean public StreamsConfig streamsConfig(KafkaProperties properties){ Properties props = new Properties(); props.put(StreamsConfig.APPLICATION_ID_CONFIG, "kafka-streams-app"); props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092"); props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass()); props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass()); // Add any additional properties as needed return new StreamsConfig(props); }

vishal now its asking mandatory credit card -its saying error as Forbidden: No credit card on file

I appreciate your great work. But one suggestion you are using deprecated classes . it will be great avoid using deprecated classes, methods

Hey how you can handle errors lets say destination connector is down/ Mq is down etc

Hi, I have one question... can this kafka sink connector be used to connect 100 different databases ? Need your input on this

But where we used schema registry? We haven't used anywhere

Can you please help me in setting up confluent center , i want know what changes has to be made in properties file to run control center for cluster in confluent cloud locally Your reply means a lot

Can you also do a video using Confluent Kafka Client Java? My Java application cannot connect to the Confluent Cloud cluster.

can I use same commands to apache kafka?

How to do the same using spring cloud.stream.bindings. Im trying to use schema related configs to the binding consumer but im getting schema.registry.url was supplied bit isnt a known config. So can you help how to configure schema configs to a binding a consumer please

Does this works in Android as well consider it is working in IntelliJ?

can we connect tibco ems to kafka.

Simple concise and elegant. Great work.

Thank for the great tutorial. Did you have to create the avro schema or it gets generated?

Great... Nicely explained 👌

my schema registry is continuously throwing error. need help asap.

Hi Michel, thks for the videos and explains,these are really useful, but, I suggest you add kerberos, and how can implement it,