Update IP Kafka

Author: DucBaoUIT

src/main/java/com/programming/videoService/config/KafkaConsumerConfig.java

@@ -19,7 +19,7 @@ public class KafkaConsumerConfig {
     @Bean
     public Map<String, Object> consumerConfigs() {
         Map<String, Object> props = new HashMap<>();
-        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.2.240:9092");
+        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.120.131:9092");
         props.put(ConsumerConfig.GROUP_ID_CONFIG, "video-genres-group"); // Tên group ID
         props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
         props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);

src/main/java/com/programming/videoService/config/KafkaProducerConfig.java

@@ -16,7 +16,7 @@ public class KafkaProducerConfig {
     @Bean
     public Map<String, Object> producerConfigs() {
         Map<String, Object> props = new HashMap<>();
-        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.2.240:9092");
+        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.120.131:9092");
         props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
         props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
         return props;

src/main/java/com/programming/videoService/service/VideoService.java

@@ -87,14 +87,14 @@ public class VideoService {
     public VideoService() {
         // Kafka Producer Configuration
         Properties producerProps = new Properties();
-        producerProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.120.131:30392");
+        producerProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.120.131:9092");
         producerProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
         producerProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
         this.kafkaProducer = new KafkaProducer<>(producerProps);
 
         // Kafka Consumer Configuration
         Properties consumerProps = new Properties();
-        consumerProps.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.169.120.131:30392");
+        consumerProps.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.169.120.131:9092");
         consumerProps.put(ConsumerConfig.GROUP_ID_CONFIG, "video-genres-group");
         consumerProps.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
         consumerProps.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());

src/main/resources/application.yml

@@ -10,7 +10,7 @@ spring:
 
 
   kafka:
-    bootstrap-servers: 192.168.2.240:9092
+    bootstrap-servers: 192.168.120.131:9092
     producer:
       key-serializer: org.apache.kafka.common.serialization.StringSerializer
       value-serializer: org.springframework.kafka.support.serializer.JsonSerializer