Subscribe to the Kafka cluster of a topic data into es, and according to the subscription log content product, event_time create index index name is aqueducts_product_ year month day, type determined by service