diff --git a/src/main/scala/org/apache/spark/sql/pulsar/PulsarConfigurationUtils.scala b/src/main/scala/org/apache/spark/sql/pulsar/PulsarConfigurationUtils.scala index 621d21c..39c1386 100644 --- a/src/main/scala/org/apache/spark/sql/pulsar/PulsarConfigurationUtils.scala +++ b/src/main/scala/org/apache/spark/sql/pulsar/PulsarConfigurationUtils.scala @@ -18,17 +18,15 @@ import java.util.Locale import scala.reflect._ -import org.apache.pulsar.client.impl.conf.{ - ClientConfigurationData, - ProducerConfigurationData, - ReaderConfigurationData -} +import com.fasterxml.jackson.annotation.JsonIgnore +import org.apache.pulsar.client.impl.conf.{ClientConfigurationData, ProducerConfigurationData, ReaderConfigurationData} object PulsarConfigurationUtils { private def nonIgnoredFields[T: ClassTag] = { classTag[T].runtimeClass.getDeclaredFields .filter(f => !Modifier.isStatic(f.getModifiers)) + .filter(f => f.getDeclaredAnnotation(classOf[JsonIgnore]) == null) .map(_.getName) }