|
|
|
@ -15,17 +15,13 @@ |
|
|
|
*/ |
|
|
|
package org.thingsboard.rule.engine.kafka; |
|
|
|
|
|
|
|
import com.fasterxml.jackson.annotation.JsonIgnore; |
|
|
|
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|
|
|
import lombok.Data; |
|
|
|
import org.apache.kafka.common.serialization.StringSerializer; |
|
|
|
import org.thingsboard.rule.engine.api.NodeConfiguration; |
|
|
|
|
|
|
|
import java.util.Collections; |
|
|
|
import java.util.Map; |
|
|
|
|
|
|
|
@Data |
|
|
|
@JsonIgnoreProperties(ignoreUnknown = true) |
|
|
|
public class TbKafkaNodeConfiguration implements NodeConfiguration<TbKafkaNodeConfiguration> { |
|
|
|
|
|
|
|
private String topicPattern; |
|
|
|
|