INNER CODE UNIT · Java
EventSupport
chaokunyang/jkes · jkes-boot/jkes-spring-data-jpa/src/main/java/com/timeyang/jkes/spring/jpa/EventSupport.java:54
public class EventSupport {
private final JkesProperties jkesProperties;
private final JkesKafkaProducer jkesKafkaProducer;
private final IndicesAdminClient indicesAdminClient;
private final KafkaConnectClient kafkaConnectClient;
private final String deleteTopic;
@PersistenceContext
private EntityManager em;
@Inject
public EventSupport(JkesProperties jkesProperties, JkesKafkaProducer jkesKafkaProducer, IndicesAdminClient indicesAdminClient, KafkaConnectClient kafkaConnectClient) {
this.jkesProperties = jkesProperties;
this.jkesKafkaProducer = jkesKafkaProducer;
this.indicesAdminClient = indicesAdminClient;
this.kafkaConnectClient = kafkaConnectClient;
this.deleteTopic = KafkaUtils.getDeleteTopic();