/*
 * Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
 * Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
 */
package com.megatim.apifdxweb.service.impl.camel.component;

import javax.enterprise.context.ApplicationScoped;
import javax.inject.Inject;
import org.apache.camel.CamelContext;
import org.apache.camel.component.kafka.KafkaComponent;

/**
 *
 * @author ASUS
 */
@ApplicationScoped
public class KafkaComponentConfiguration {

    @Inject
    CamelContext camelContext;

    @Inject
    public void configureKafkaComponent() {
        KafkaComponent kafkaComponent = new KafkaComponent();
        kafkaComponent.getConfiguration().setBrokers("localhost:9092");
        camelContext.addComponent("kafka", kafkaComponent);
    }
}