{"id":46930,"date":"2022-12-26T20:56:42","date_gmt":"2023-09-08T10:49:41","guid":{"rendered":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%88%a9%e7%94%a8storm%e5%a4%84%e7%90%86kafka%e4%b8%bb%e9%a2%98%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87apache-atlas%e6%98%be%e7%a4%balineage%e7%9a%84%e5%86%85%e5%ae%b9%e3%80%82\/"},"modified":"2024-04-29T07:05:13","modified_gmt":"2024-04-28T23:05:13","slug":"%e5%88%a9%e7%94%a8storm%e5%a4%84%e7%90%86kafka%e4%b8%bb%e9%a2%98%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87apache-atlas%e6%98%be%e7%a4%balineage%e7%9a%84%e5%86%85%e5%ae%b9%e3%80%82","status":"publish","type":"post","link":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%88%a9%e7%94%a8storm%e5%a4%84%e7%90%86kafka%e4%b8%bb%e9%a2%98%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87apache-atlas%e6%98%be%e7%a4%balineage%e7%9a%84%e5%86%85%e5%ae%b9%e3%80%82\/","title":{"rendered":"\u5229\u7528Storm\u5904\u7406Kafka\u4e3b\u9898\uff0c\u5e76\u901a\u8fc7Apache Atlas\u663e\u793aLineage\u7684\u5185\u5bb9"},"content":{"rendered":"

\u65e5\u5fd7<\/h2>\n
\u5b9f\u884c\u30ed\u30b0[centos@zzeng-hdp-1 ~\/sandbox\/crosscomponent_demo\/crosscomponent_scripts\/storm-demo]$ .\/004-run-storm-job.sh
\nRunning: \/usr\/jdk64\/jdk1.8.0_112\/bin\/java -server -Ddaemon.name= -Dstorm.options= -Dstorm.home=\/usr\/hdp\/3.1.0.0-78\/storm -Dstorm.log.dir=\/var\/log\/storm -Djava.library.path=\/usr\/local\/lib:\/opt\/local\/lib:\/usr\/lib -Dstorm.conf.file= -cp \/usr\/hdp\/3.1.0.0-78\/storm\/*:\/usr\/hdp\/3.1.0.0-78\/storm\/lib\/*:\/usr\/hdp\/3.1.0.0-78\/storm\/extlib\/* org.apache.storm.daemon.ClientJarTransformerRunner org.apache.storm.hack.StormShadeTransformer \/home\/centos\/sandbox\/crosscomponent_demo\/crosscomponent_scripts\/storm-demo\/lib\/storm-samples-1.0-jar-with-dependencies.jar \/tmp\/bdd4785432d311e9b3aefa163e67d972.jar
\n998 [main] WARN o.a.s.h.DefaultShader – Relocating storm\/trident\/state\/StateFactory to org\/apache\/storm\/trident\/state\/StateFactory in storm\/kafka\/trident\/TridentKafkaStateFactory.class. please modify your code to use the new namespace
\n1004 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/task\/IMetricsContext to org\/apache\/storm\/task\/IMetricsContext in storm\/kafka\/trident\/TridentKafkaStateFactory.class. please modify your code to use the new namespace
\n1005 [main] WARN o.a.s.h.DefaultShader – Relocating storm\/trident\/state\/State to org\/apache\/storm\/trident\/state\/State in storm\/kafka\/trident\/TridentKafkaStateFactory.class. please modify your code to use the new namespace
\n1017 [main] WARN o.a.s.h.DefaultShader – Relocating storm\/trident\/spout\/IOpaquePartitionedTridentSpout$Emitter to org\/apache\/storm\/trident\/spout\/IOpaquePartitionedTridentSpout$Emitter in storm\/kafka\/trident\/TridentKafkaEmitter.class. please modify your code to use the new namespace
\n1018 [main] WARN o.a.s.h.DefaultShader – Relocating storm\/trident\/spout\/IOpaquePartitionedTridentSpout to org\/apache\/storm\/trident\/spout\/IOpaquePartitionedTridentSpout in storm\/kafka\/trident\/TridentKafkaEmitter.class. please modify your code to use the new namespace
\n1018 [main] WARN o.a.s.h.DefaultShader – Relocating storm\/trident\/spout\/IPartitionedTridentSpout$Emitter to org\/apache\/storm\/trident\/spout\/IPartitionedTridentSpout$Emitter in storm\/kafka\/trident\/TridentKafkaEmitter.class. please modify your code to use the new namespace
\n1018 [main] WARN o.a.s.h.DefaultShader – Relocating storm\/trident\/spout\/IPartitionedTridentSpout to org\/apache\/storm\/trident\/spout\/IPartitionedTridentSpout in storm\/kafka\/trident\/TridentKafkaEmitter.class. please modify your code to use the new namespace
\n1018 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/metric\/api\/ReducedMetric to org\/apache\/storm\/metric\/api\/ReducedMetric in storm\/kafka\/trident\/TridentKafkaEmitter.class. please modify your code to use the new namespace
\n1019 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/metric\/api\/CombinedMetric to org\/apache\/storm\/metric\/api\/CombinedMetric in storm\/kafka\/trident\/TridentKafkaEmitter.class. please modify your code to use the new namespace
\n1019 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/task\/TopologyContext to org\/apache\/storm\/task\/TopologyContext in storm\/kafka\/trident\/TridentKafkaEmitter.class. please modify your code to use the new namespace
\n1020 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/metric\/api\/IMetric to org\/apache\/storm\/metric\/api\/IMetric in storm\/kafka\/trident\/TridentKafkaEmitter.class. please modify your code to use the new namespace
\n1021 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/metric\/api\/MeanReducer to org\/apache\/storm\/metric\/api\/MeanReducer in storm\/kafka\/trident\/TridentKafkaEmitter.class. please modify your code to use the new namespace
\n1022 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/metric\/api\/IReducer to org\/apache\/storm\/metric\/api\/IReducer in storm\/kafka\/trident\/TridentKafkaEmitter.class. please modify your code to use the new namespace
\n1022 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/metric\/api\/ICombiner to org\/apache\/storm\/metric\/api\/ICombiner in storm\/kafka\/trident\/TridentKafkaEmitter.class. please modify your code to use the new namespace
\n1023 [main] WARN o.a.s.h.DefaultShader – Relocating storm\/trident\/topology\/TransactionAttempt to org\/apache\/storm\/trident\/topology\/TransactionAttempt in storm\/kafka\/trident\/TridentKafkaEmitter.class. please modify your code to use the new namespace
\n1023 [main] WARN o.a.s.h.DefaultShader – Relocating storm\/trident\/operation\/TridentCollector to org\/apache\/storm\/trident\/operation\/TridentCollector in storm\/kafka\/trident\/TridentKafkaEmitter.class. please modify your code to use the new namespace
\n1042 [main] WARN o.a.s.h.DefaultShader – Relocating storm\/trident\/spout\/IOpaquePartitionedTridentSpout$Coordinator to org\/apache\/storm\/trident\/spout\/IOpaquePartitionedTridentSpout$Coordinator in storm\/kafka\/trident\/OpaqueTridentKafkaSpout.class. please modify your code to use the new namespace
\n1043 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/tuple\/Fields to org\/apache\/storm\/tuple\/Fields in storm\/kafka\/trident\/OpaqueTridentKafkaSpout.class. please modify your code to use the new namespace
\n1044 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/spout\/MultiScheme to org\/apache\/storm\/spout\/MultiScheme in storm\/kafka\/trident\/OpaqueTridentKafkaSpout.class. please modify your code to use the new namespace
\n1045 [main] WARN o.a.s.h.DefaultShader – Relocating storm\/trident\/state\/BaseStateUpdater to org\/apache\/storm\/trident\/state\/BaseStateUpdater in storm\/kafka\/trident\/TridentKafkaUpdater.class. please modify your code to use the new namespace
\n1045 [main] WARN o.a.s.h.DefaultShader – Relocating storm\/trident\/tuple\/TridentTuple to org\/apache\/storm\/trident\/tuple\/TridentTuple in storm\/kafka\/trident\/TridentKafkaUpdater.class. please modify your code to use the new namespace
\n1050 [main] WARN o.a.s.h.DefaultShader – Relocating storm\/trident\/spout\/ISpoutPartition to org\/apache\/storm\/trident\/spout\/ISpoutPartition in storm\/kafka\/trident\/TridentKafkaEmitter$1.class. please modify your code to use the new namespace
\n1054 [main] WARN o.a.s.h.DefaultShader – Relocating storm\/trident\/spout\/IPartitionedTridentSpout$Coordinator to org\/apache\/storm\/trident\/spout\/IPartitionedTridentSpout$Coordinator in storm\/kafka\/trident\/TransactionalTridentKafkaSpout.class. please modify your code to use the new namespace
\n1062 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/task\/OutputCollector to org\/apache\/storm\/task\/OutputCollector in storm\/kafka\/trident\/TridentKafkaState.class. please modify your code to use the new namespace
\n1064 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/topology\/FailedException to org\/apache\/storm\/topology\/FailedException in storm\/kafka\/trident\/TridentKafkaState.class. please modify your code to use the new namespace
\n1072 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/tuple\/Values to org\/apache\/storm\/tuple\/Values in storm\/kafka\/StringKeyValueScheme.class. please modify your code to use the new namespace
\n1074 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/utils\/Utils to org\/apache\/storm\/utils\/Utils in storm\/kafka\/ZkState.class. please modify your code to use the new namespace
\n1079 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/spout\/SpoutOutputCollector to org\/apache\/storm\/spout\/SpoutOutputCollector in storm\/kafka\/KafkaSpout$2.class. please modify your code to use the new namespace
\n1082 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/tuple\/Tuple to org\/apache\/storm\/tuple\/Tuple in storm\/kafka\/bolt\/mapper\/FieldNameBasedTupleToKafkaMapper.class. please modify your code to use the new namespace
\n1084 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/topology\/base\/BaseRichBolt to org\/apache\/storm\/topology\/base\/BaseRichBolt in storm\/kafka\/bolt\/KafkaBolt.class. please modify your code to use the new namespace
\n1085 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/utils\/TupleUtils to org\/apache\/storm\/utils\/TupleUtils in storm\/kafka\/bolt\/KafkaBolt.class. please modify your code to use the new namespace
\n1086 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/topology\/OutputFieldsDeclarer to org\/apache\/storm\/topology\/OutputFieldsDeclarer in storm\/kafka\/bolt\/KafkaBolt.class. please modify your code to use the new namespace
\n1092 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/spout\/Scheme to org\/apache\/storm\/spout\/Scheme in storm\/kafka\/KeyValueScheme.class. please modify your code to use the new namespace
\n1120 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/topology\/base\/BaseRichSpout to org\/apache\/storm\/topology\/base\/BaseRichSpout in storm\/kafka\/KafkaSpout.class. please modify your code to use the new namespace
\n1127 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/spout\/RawMultiScheme to org\/apache\/storm\/spout\/RawMultiScheme in storm\/kafka\/KafkaConfig.class. please modify your code to use the new namespace
\n1129 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/spout\/SchemeAsMultiScheme to org\/apache\/storm\/spout\/SchemeAsMultiScheme in storm\/kafka\/KeyValueSchemeAsMultiScheme.class. please modify your code to use the new namespace
\n1137 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/metric\/api\/CountMetric to org\/apache\/storm\/metric\/api\/CountMetric in storm\/kafka\/PartitionManager.class. please modify your code to use the new namespace
\n5151 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/security\/auth\/IAutoCredentials to org\/apache\/storm\/security\/auth\/IAutoCredentials in org\/apache\/storm\/hdfs\/common\/security\/AutoHDFS.class. please modify your code to use the new namespace
\n5152 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/security\/auth\/ICredentialsRenewer to org\/apache\/storm\/security\/auth\/ICredentialsRenewer in org\/apache\/storm\/hdfs\/common\/security\/AutoHDFS.class. please modify your code to use the new namespace
\n5152 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/security\/INimbusCredentialPlugin to org\/apache\/storm\/security\/INimbusCredentialPlugin in org\/apache\/storm\/hdfs\/common\/security\/AutoHDFS.class. please modify your code to use the new namespace
\n5154 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/security\/auth\/kerberos\/AutoTGT to org\/apache\/storm\/security\/auth\/kerberos\/AutoTGT in org\/apache\/storm\/hdfs\/common\/security\/HdfsSecurityUtil.class. please modify your code to use the new namespace
\n5170 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/Config to org\/apache\/storm\/Config in org\/apache\/storm\/hdfs\/bolt\/AbstractHdfsBolt.class. please modify your code to use the new namespace
\n5184 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/codedistributor\/ICodeDistributor to org\/apache\/storm\/codedistributor\/ICodeDistributor in org\/apache\/storm\/hdfs\/ha\/codedistributor\/HDFSCodeDistributor.class. please modify your code to use the new namespace
\n60125 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/topology\/base\/BaseBasicBolt to org\/apache\/storm\/topology\/base\/BaseBasicBolt in com\/dsinpractice\/storm\/samples\/WordCountTopology$JavaSplitSentence.class. please modify your code to use the new namespace
\n60126 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/topology\/BasicOutputCollector to org\/apache\/storm\/topology\/BasicOutputCollector in com\/dsinpractice\/storm\/samples\/WordCountTopology$JavaSplitSentence.class. please modify your code to use the new namespace
\n60127 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/topology\/TopologyBuilder to org\/apache\/storm\/topology\/TopologyBuilder in com\/dsinpractice\/storm\/samples\/WordCountTopology.class. please modify your code to use the new namespace
\n60128 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/generated\/StormTopology to org\/apache\/storm\/generated\/StormTopology in com\/dsinpractice\/storm\/samples\/WordCountTopology.class. please modify your code to use the new namespace
\n60128 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/StormSubmitter to org\/apache\/storm\/StormSubmitter in com\/dsinpractice\/storm\/samples\/WordCountTopology.class. please modify your code to use the new namespace
\n60128 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/topology\/IRichSpout to org\/apache\/storm\/topology\/IRichSpout in com\/dsinpractice\/storm\/samples\/WordCountTopology.class. please modify your code to use the new namespace
\n60128 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/topology\/SpoutDeclarer to org\/apache\/storm\/topology\/SpoutDeclarer in com\/dsinpractice\/storm\/samples\/WordCountTopology.class. please modify your code to use the new namespace
\n60129 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/topology\/IBasicBolt to org\/apache\/storm\/topology\/IBasicBolt in com\/dsinpractice\/storm\/samples\/WordCountTopology.class. please modify your code to use the new namespace
\n60129 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/topology\/BoltDeclarer to org\/apache\/storm\/topology\/BoltDeclarer in com\/dsinpractice\/storm\/samples\/WordCountTopology.class. please modify your code to use the new namespace
\n60129 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/topology\/InputDeclarer to org\/apache\/storm\/topology\/InputDeclarer in com\/dsinpractice\/storm\/samples\/WordCountTopology.class. please modify your code to use the new namespace
\n60129 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/topology\/IRichBolt to org\/apache\/storm\/topology\/IRichBolt in com\/dsinpractice\/storm\/samples\/WordCountTopology.class. please modify your code to use the new namespace
\n60130 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/generated\/AlreadyAliveException to org\/apache\/storm\/generated\/AlreadyAliveException in com\/dsinpractice\/storm\/samples\/WordCountTopology.class. please modify your code to use the new namespace
\n60130 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/generated\/InvalidTopologyException to org\/apache\/storm\/generated\/InvalidTopologyException in com\/dsinpractice\/storm\/samples\/WordCountTopology.class. please modify your code to use the new namespace
\n60130 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/Testing to org\/apache\/storm\/Testing in com\/dsinpractice\/storm\/samples\/WordCountTopology.class. please modify your code to use the new namespace
\n60130 [main] WARN o.a.s.h.DefaultShader – Relocating backtype\/storm\/ILocalCluster to org\/apache\/storm\/ILocalCluster in com\/dsinpractice\/storm\/samples\/WordCountTopology.class. please modify your code to use the new namespace
\nRunning: \/usr\/jdk64\/jdk1.8.0_112\/bin\/java -Ddaemon.name= -Dstorm.options= -Dstorm.home=\/usr\/hdp\/3.1.0.0-78\/storm -Dstorm.log.dir=\/var\/log\/storm -Djava.library.path=\/usr\/local\/lib:\/opt\/local\/lib:\/usr\/lib -Dstorm.conf.file= -cp \/usr\/hdp\/3.1.0.0-78\/storm\/*:\/usr\/hdp\/3.1.0.0-78\/storm\/lib\/*:\/usr\/hdp\/3.1.0.0-78\/storm\/extlib\/*:\/tmp\/bdd4785432d311e9b3aefa163e67d972.jar:\/usr\/hdp\/current\/storm-client\/conf:\/usr\/hdp\/3.1.0.0-78\/storm\/bin -Dstorm.jar=\/tmp\/bdd4785432d311e9b3aefa163e67d972.jar -Dstorm.dependency.jars= -Dstorm.dependency.artifacts={} com.dsinpractice.storm.samples.WordCountTopology –cluster true –name storm-demo-topology-01 –path \/user\/storm\/storm-hdfs-test-01 –topic my-topic-01
\n1418 [main] INFO o.a.s.h.b.AbstractHdfsBolt – Enabling tick tuple with interval [1]
\n1703 [main] WARN o.a.s.u.Utils – STORM-VERSION new 1.2.1.3.1.0.0-78 old null
\n1741 [main] INFO o.a.s.StormSubmitter – Generated ZooKeeper secret payload for MD5-digest: -6887613048810109930:-7282845338058760974
\n1918 [main] INFO o.a.s.u.NimbusClient – Found leader nimbus : zzeng-hdp-1.field.hortonworks.com:6627
\n1956 [main] INFO o.a.s.s.a.AuthUtils – Got AutoCreds []
\n1967 [main] INFO o.a.s.u.NimbusClient – Found leader nimbus : zzeng-hdp-1.field.hortonworks.com:6627
\n2067 [main] INFO o.a.s.StormSubmitter – Uploading dependencies – jars…
\n2068 [main] INFO o.a.s.StormSubmitter – Uploading dependencies – artifacts…
\n2069 [main] INFO o.a.s.StormSubmitter – Dependency Blob keys – jars : [] \/ artifacts : []
\n2075 [main] INFO o.a.s.StormSubmitter – Uploading topology jar \/tmp\/bdd4785432d311e9b3aefa163e67d972.jar to assigned location: \/hadoop\/storm\/nimbus\/inbox\/stormjar-7f8a776d-65bd-42d7-a210-0ceca964b773.jar
\n3485 [main] INFO o.a.s.StormSubmitter – Successfully uploaded topology jar to assigned location: \/hadoop\/storm\/nimbus\/inbox\/stormjar-7f8a776d-65bd-42d7-a210-0ceca964b773.jar
\n3485 [main] INFO o.a.s.StormSubmitter – Submitting topology storm-demo-topology-01 in distributed mode with conf {“storm.zookeeper.topology.auth.scheme”:”digest”,”storm.zookeeper.topology.auth.payload”:”-6887613048810109930:-7282845338058760974″,”topology.workers”:3,”topology.debug”:true}
\n3485 [main] WARN o.a.s.u.Utils – STORM-VERSION new 1.2.1.3.1.0.0-78 old 1.2.1.3.1.0.0-78
\n4109 [main] INFO o.a.s.StormSubmitter – Finished submitting topology: storm-demo-topology-01
\n4109 [main] INFO o.a.s.StormSubmitter – Initializing the registered ISubmitterHook [org.apache.atlas.storm.hook.StormAtlasHook]
\n4217 [main] INFO o.a.a.ApplicationProperties – Looking for atlas-application.properties in classpath
\n4217 [main] INFO o.a.a.ApplicationProperties – Loading atlas-application.properties from file:\/etc\/storm\/3.1.0.0-78\/0\/atlas-application.properties
\nlog4j:ERROR A “org.apache.log4j.ConsoleAppender” object is not assignable to a “org.apache.log4j.Appender” variable.
\nlog4j:ERROR The class “org.apache.log4j.Appender” was loaded by
\nlog4j:ERROR [org.apache.atlas.plugin.classloader.AtlasPluginClassLoader@7c7d3c46] whereas object of type
\nlog4j:ERROR “org.apache.log4j.ConsoleAppender” was loaded by [sun.misc.Launcher$AppClassLoader@6ff3c5b5].
\nlog4j:ERROR Could not instantiate appender named “stdout”.
\n4296 [main] INFO o.a.a.ApplicationProperties – No graphdb backend specified. Will use ‘janus’
\n4296 [main] INFO o.a.a.ApplicationProperties – Using storage backend ‘hbase2’
\n4297 [main] INFO o.a.a.ApplicationProperties – Using index backend ‘solr’
\n4297 [main] INFO o.a.a.ApplicationProperties – Setting solr-wait-searcher property ‘true’
\n4297 [main] INFO o.a.a.ApplicationProperties – Setting index.search.map-name property ‘false’
\n4305 [main] INFO o.a.a.ApplicationProperties – Property (set to default) atlas.graph.cache.db-cache = true
\n4306 [main] INFO o.a.a.ApplicationProperties – Property (set to default) atlas.graph.cache.db-cache-clean-wait = 20
\n4306 [main] INFO o.a.a.ApplicationProperties – Property (set to default) atlas.graph.cache.db-cache-size = 0.5
\n4306 [main] INFO o.a.a.ApplicationProperties – Property (set to default) atlas.graph.cache.tx-cache-size = 15000
\n4306 [main] INFO o.a.a.ApplicationProperties – Property (set to default) atlas.graph.cache.tx-dirty-size = 120
\n4680 [main] WARN o.a.a.h.AtlasHook – Error in determining keytab for KafkaClient-JAAS config
\njava.lang.RuntimeException: java.lang.RuntimeException: class org.apache.hadoop.security.JniBasedUnixGroupsMappingWithFallback not org.apache.hadoop.security.GroupMappingServiceProvider
\nat org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2628) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.Groups.(Groups.java:107) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.Groups.(Groups.java:102) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.Groups.getUserToGroupsMappingService(Groups.java:451) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.initialize(UserGroupInformation.java:337) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.ensureInitialized(UserGroupInformation.java:304) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.doSubjectLogin(UserGroupInformation.java:1828) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.createLoginUser(UserGroupInformation.java:710) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.getLoginUser(UserGroupInformation.java:660) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.isLoginKeytabBased(UserGroupInformation.java:1236) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.atlas.hook.AtlasHook.isLoginKeytabBased(AtlasHook.java:288) [atlas-notification-1.1.0.3.1.0.0-78.jar:1.1.0.3.1.0.0-78]
\nat org.apache.atlas.hook.AtlasHook.(AtlasHook.java:92) [atlas-notification-1.1.0.3.1.0.0-78.jar:1.1.0.3.1.0.0-78]
\nat java.lang.Class.forName0(Native Method) ~[?:1.8.0_112]
\nat java.lang.Class.forName(Class.java:348) [?:1.8.0_112]
\nat org.apache.atlas.storm.hook.StormAtlasHook.initialize(StormAtlasHook.java:78) [storm-bridge-shim-1.1.0.3.1.0.0-78.jar:1.1.0.3.1.0.0-78]
\nat org.apache.atlas.storm.hook.StormAtlasHook.(StormAtlasHook.java:46) [storm-bridge-shim-1.1.0.3.1.0.0-78.jar:1.1.0.3.1.0.0-78]
\nat sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[?:1.8.0_112]
\nat sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) [?:1.8.0_112]
\nat sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) [?:1.8.0_112]
\nat java.lang.reflect.Constructor.newInstance(Constructor.java:423) [?:1.8.0_112]
\nat java.lang.Class.newInstance(Class.java:442) [?:1.8.0_112]
\nat org.apache.storm.StormSubmitter.invokeSubmitterHook(StormSubmitter.java:358) [storm-core-1.2.1.3.1.0.0-78.jar:1.2.1.3.1.0.0-78]
\nat org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:275) [storm-core-1.2.1.3.1.0.0-78.jar:1.2.1.3.1.0.0-78]
\nat org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:387) [storm-core-1.2.1.3.1.0.0-78.jar:1.2.1.3.1.0.0-78]
\nat org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:159) [storm-core-1.2.1.3.1.0.0-78.jar:1.2.1.3.1.0.0-78]
\nat com.dsinpractice.storm.samples.WordCountTopology.main(WordCountTopology.java:140) [bdd4785432d311e9b3aefa163e67d972.jar:?]
\nCaused by: java.lang.RuntimeException: class org.apache.hadoop.security.JniBasedUnixGroupsMappingWithFallback not org.apache.hadoop.security.GroupMappingServiceProvider
\nat org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2622) ~[bdd4785432d311e9b3aefa163e67d972.jar:?]
\n… 25 more
\n4698 [main] WARN o.a.a.h.AtlasHook – Error in determining ticket-cache for KafkaClient-JAAS config
\njava.lang.RuntimeException: java.lang.RuntimeException: class org.apache.hadoop.security.JniBasedUnixGroupsMappingWithFallback not org.apache.hadoop.security.GroupMappingServiceProvider
\nat org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2628) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.Groups.(Groups.java:107) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.Groups.(Groups.java:102) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.Groups.getUserToGroupsMappingService(Groups.java:451) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.initialize(UserGroupInformation.java:337) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.ensureInitialized(UserGroupInformation.java:304) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.doSubjectLogin(UserGroupInformation.java:1828) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.createLoginUser(UserGroupInformation.java:710) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.getLoginUser(UserGroupInformation.java:660) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.isLoginTicketBased(UserGroupInformation.java:1244) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.atlas.hook.AtlasHook.isLoginTicketBased(AtlasHook.java:300) [atlas-notification-1.1.0.3.1.0.0-78.jar:1.1.0.3.1.0.0-78]
\nat org.apache.atlas.hook.AtlasHook.(AtlasHook.java:93) [atlas-notification-1.1.0.3.1.0.0-78.jar:1.1.0.3.1.0.0-78]
\nat java.lang.Class.forName0(Native Method) ~[?:1.8.0_112]
\nat java.lang.Class.forName(Class.java:348) [?:1.8.0_112]
\nat org.apache.atlas.storm.hook.StormAtlasHook.initialize(StormAtlasHook.java:78) [storm-bridge-shim-1.1.0.3.1.0.0-78.jar:1.1.0.3.1.0.0-78]
\nat org.apache.atlas.storm.hook.StormAtlasHook.(StormAtlasHook.java:46) [storm-bridge-shim-1.1.0.3.1.0.0-78.jar:1.1.0.3.1.0.0-78]
\nat sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[?:1.8.0_112]
\nat sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) [?:1.8.0_112]
\nat sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) [?:1.8.0_112]
\nat java.lang.reflect.Constructor.newInstance(Constructor.java:423) [?:1.8.0_112]
\nat java.lang.Class.newInstance(Class.java:442) [?:1.8.0_112]
\nat org.apache.storm.StormSubmitter.invokeSubmitterHook(StormSubmitter.java:358) [storm-core-1.2.1.3.1.0.0-78.jar:1.2.1.3.1.0.0-78]
\nat org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:275) [storm-core-1.2.1.3.1.0.0-78.jar:1.2.1.3.1.0.0-78]
\nat org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:387) [storm-core-1.2.1.3.1.0.0-78.jar:1.2.1.3.1.0.0-78]
\nat org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:159) [storm-core-1.2.1.3.1.0.0-78.jar:1.2.1.3.1.0.0-78]
\nat com.dsinpractice.storm.samples.WordCountTopology.main(WordCountTopology.java:140) [bdd4785432d311e9b3aefa163e67d972.jar:?]
\nCaused by: java.lang.RuntimeException: class org.apache.hadoop.security.JniBasedUnixGroupsMappingWithFallback not org.apache.hadoop.security.GroupMappingServiceProvider
\nat org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2622) ~[bdd4785432d311e9b3aefa163e67d972.jar:?]
\n… 25 more
\n4716 [main] INFO o.a.a.k.KafkaNotification – ==> KafkaNotification()
\n4719 [main] INFO o.a.a.k.KafkaNotification – <== KafkaNotification()
\n4728 [main] WARN o.a.a.h.AtlasHook – Error in determining current user
\njava.lang.RuntimeException: java.lang.RuntimeException: class org.apache.hadoop.security.JniBasedUnixGroupsMappingWithFallback not org.apache.hadoop.security.GroupMappingServiceProvider
\nat org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2628) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.Groups.(Groups.java:107) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.Groups.(Groups.java:102) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.Groups.getUserToGroupsMappingService(Groups.java:451) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.initialize(UserGroupInformation.java:337) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.ensureInitialized(UserGroupInformation.java:304) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.doSubjectLogin(UserGroupInformation.java:1828) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.createLoginUser(UserGroupInformation.java:710) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.getLoginUser(UserGroupInformation.java:660) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.hadoop.security.UserGroupInformation.getCurrentUser(UserGroupInformation.java:571) ~[hadoop-common-3.1.1.3.1.0.0-78.jar:?]
\nat org.apache.atlas.hook.AtlasHook.getUser(AtlasHook.java:277) ~[atlas-notification-1.1.0.3.1.0.0-78.jar:1.1.0.3.1.0.0-78]
\nat org.apache.atlas.hook.AtlasHook.getUser(AtlasHook.java:246) ~[atlas-notification-1.1.0.3.1.0.0-78.jar:1.1.0.3.1.0.0-78]
\nat org.apache.atlas.hook.AtlasHook.(AtlasHook.java:105) [atlas-notification-1.1.0.3.1.0.0-78.jar:1.1.0.3.1.0.0-78]
\nat java.lang.Class.forName0(Native Method) ~[?:1.8.0_112]
\nat java.lang.Class.forName(Class.java:348) [?:1.8.0_112]
\nat org.apache.atlas.storm.hook.StormAtlasHook.initialize(StormAtlasHook.java:78) [storm-bridge-shim-1.1.0.3.1.0.0-78.jar:1.1.0.3.1.0.0-78]
\nat org.apache.atlas.storm.hook.StormAtlasHook.(StormAtlasHook.java:46) [storm-bridge-shim-1.1.0.3.1.0.0-78.jar:1.1.0.3.1.0.0-78]
\nat sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[?:1.8.0_112]
\nat sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) [?:1.8.0_112]
\nat sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) [?:1.8.0_112]
\nat java.lang.reflect.Constructor.newInstance(Constructor.java:423) [?:1.8.0_112]
\nat java.lang.Class.newInstance(Class.java:442) [?:1.8.0_112]
\nat org.apache.storm.StormSubmitter.invokeSubmitterHook(StormSubmitter.java:358) [storm-core-1.2.1.3.1.0.0-78.jar:1.2.1.3.1.0.0-78]
\nat org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:275) [storm-core-1.2.1.3.1.0.0-78.jar:1.2.1.3.1.0.0-78]
\nat org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:387) [storm-core-1.2.1.3.1.0.0-78.jar:1.2.1.3.1.0.0-78]
\nat org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:159) [storm-core-1.2.1.3.1.0.0-78.jar:1.2.1.3.1.0.0-78]
\nat com.dsinpractice.storm.samples.WordCountTopology.main(WordCountTopology.java:140) [bdd4785432d311e9b3aefa163e67d972.jar:?]
\nCaused by: java.lang.RuntimeException: class org.apache.hadoop.security.JniBasedUnixGroupsMappingWithFallback not org.apache.hadoop.security.GroupMappingServiceProvider
\nat org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2622) ~[bdd4785432d311e9b3aefa163e67d972.jar:?]
\n… 26 more
\n4741 [main] INFO o.a.a.h.AtlasHook – Created Atlas Hook
\n4751 [main] INFO o.a.s.u.NimbusClient – Found leader nimbus : zzeng-hdp-1.field.hortonworks.com:6627
\n5093 [main] INFO o.a.s.StormSubmitter – Invoking the registered ISubmitterHook [org.apache.atlas.storm.hook.StormAtlasHook]
\n5094 [main] INFO o.a.a.s.h.StormAtlasHook – Collecting metadata for a new storm topology: storm-demo-topology-01
\n5695 [Atlas Notifier 0] INFO o.a.k.c.p.ProducerConfig – ProducerConfig values:
\nacks = 1
\nbatch.size = 16384
\nbootstrap.servers = [zzeng-hdp-3.field.hortonworks.com:6667, zzeng-hdp-1.field.hortonworks.com:6667, zzeng-hdp-2.field.hortonworks.com:6667]
\nbuffer.memory = 33554432
\nclient.id =
\ncompression.type = none
\nconnections.max.idle.ms = 540000
\nenable.idempotence = false
\ninterceptor.classes = []
\nkey.serializer = class org.apache.kafka.common.serialization.StringSerializer
\nlinger.ms = 0
\nmax.block.ms = 60000
\nmax.in.flight.requests.per.connection = 5
\nmax.request.size = 1048576
\nmetadata.max.age.ms = 300000
\nmetric.reporters = []
\nmetrics.num.samples = 2
\nmetrics.recording.level = INFO
\nmetrics.sample.window.ms = 30000
\npartitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
\nreceive.buffer.bytes = 32768
\nreconnect.backoff.max.ms = 1000
\nreconnect.backoff.ms = 50
\nrequest.timeout.ms = 30000
\nretries = 0
\nretry.backoff.ms = 100
\nsasl.client.callback.handler.class = null
\nsasl.jaas.config = null
\nsasl.kerberos.kinit.cmd = \/usr\/bin\/kinit
\nsasl.kerberos.min.time.before.relogin = 60000
\nsasl.kerberos.service.name = null
\nsasl.kerberos.ticket.renew.jitter = 0.05
\nsasl.kerberos.ticket.renew.window.factor = 0.8
\nsasl.login.callback.handler.class = null
\nsasl.login.class = null
\nsasl.login.refresh.buffer.seconds = 300
\nsasl.login.refresh.min.period.seconds = 60
\nsasl.login.refresh.window.factor = 0.8
\nsasl.login.refresh.window.jitter = 0.05
\nsasl.mechanism = GSSAPI
\nsecurity.protocol = PLAINTEXT
\nsend.buffer.bytes = 131072
\nssl.cipher.suites = null
\nssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
\nssl.endpoint.identification.algorithm = https
\nssl.key.password = null
\nssl.keymanager.algorithm = SunX509
\nssl.keystore.location = null
\nssl.keystore.password = null
\nssl.keystore.type = JKS
\nssl.protocol = TLS
\nssl.provider = null
\nssl.secure.random.implementation = null
\nssl.trustmanager.algorithm = PKIX
\nssl.truststore.location = null
\nssl.truststore.password = null
\nssl.truststore.type = JKS
\ntransaction.timeout.ms = 60000
\ntransactional.id = null
\nvalue.serializer = class org.apache.kafka.common.serialization.StringSerializer<\/p>\n

5803 [Atlas Notifier 0] WARN o.a.k.c.p.ProducerConfig – The configuration ‘key.deserializer’ was supplied but isn’t a known config.
\n5803 [Atlas Notifier 0] WARN o.a.k.c.p.ProducerConfig – The configuration ‘value.deserializer’ was supplied but isn’t a known config.
\n5805 [Atlas Notifier 0] WARN o.a.k.c.p.ProducerConfig – The configuration ‘hook.group.id’ was supplied but isn’t a known config.
\n5806 [Atlas Notifier 0] WARN o.a.k.c.p.ProducerConfig – The configuration ‘zookeeper.connection.timeout.ms’ was supplied but isn’t a known config.
\n5806 [Atlas Notifier 0] WARN o.a.k.c.p.ProducerConfig – The configuration ‘zookeeper.session.timeout.ms’ was supplied but isn’t a known config.
\n5806 [Atlas Notifier 0] WARN o.a.k.c.p.ProducerConfig – The configuration ‘enable.auto.commit’ was supplied but isn’t a known config.
\n5807 [Atlas Notifier 0] WARN o.a.k.c.p.ProducerConfig – The configuration ‘zookeeper.connect’ was supplied but isn’t a known config.
\n5807 [Atlas Notifier 0] WARN o.a.k.c.p.ProducerConfig – The configuration ‘zookeeper.sync.time.ms’ was supplied but isn’t a known config.
\n5807 [Atlas Notifier 0] WARN o.a.k.c.p.ProducerConfig – The configuration ‘session.timeout.ms’ was supplied but isn’t a known config.
\n5807 [Atlas Notifier 0] WARN o.a.k.c.p.ProducerConfig – The configuration ‘auto.offset.reset’ was supplied but isn’t a known config.
\n5811 [Atlas Notifier 0] INFO o.a.k.c.u.AppInfoParser – Kafka version : 2.0.0.3.1.0.0-78
\n5811 [Atlas Notifier 0] INFO o.a.k.c.u.AppInfoParser – Kafka commitId : 0f47b27cde30d177
\n6039 [kafka-producer-network-thread | producer-1] INFO o.a.k.c.Metadata – Cluster ID: 6qrlmnM0TSanZmrZy_eGHQ
\n[centos@zzeng-hdp-1 ~\/sandbox\/crosscomponent_demo\/crosscomponent_scripts\/storm-demo]$<\/p>\n<\/details>\n

\u52fe\u4f4f\uff0c\u94a9\u4f4f<\/p>\n

4741 [<\/span>main] INFO  o.a.a.h.AtlasHook - Created Atlas Hook\r\n4751 [<\/span>main] INFO  o.a.s.u.NimbusClient - Found leader nimbus : zzeng-hdp-1.field.hortonworks.com:6627\r\n5093 [<\/span>main] INFO  o.a.s.StormSubmitter - Invoking the registered ISubmitterHook [<\/span>org.apache.atlas.storm.hook.StormAtlasHook]\r\n5094 [<\/span>main] INFO  o.a.a.s.h.StormAtlasHook - Collecting metadata for <\/span>a new storm topology: storm-demo-topology-01\r\n5695 [<\/span>Atlas Notifier 0] INFO  o.a.k.c.p.ProducerConfig - ProducerConfig values:\r\n    acks =<\/span> 1\r\n    batch.size =<\/span> 16384\r\n    bootstrap.servers =<\/span> [<\/span>zzeng-hdp-3.field.hortonworks.com:6667, zzeng-hdp-1.field.hortonworks.com:6667, zzeng-hdp-2.field.hortonworks.com:6667]\r\n    buffer.memory =<\/span> 33554432\r\n    client.id =<\/span>\r\n    compression.type =<\/span> none\r\n    connections.max.idle.ms =<\/span> 540000\r\n    enable.idempotence =<\/span> false\r\n    <\/span>interceptor.classes =<\/span> []<\/span>\r\n    key.serializer =<\/span> class org.apache.kafka.common.serialization.StringSerializer\r\n    linger.ms =<\/span> 0\r\n    max.block.ms =<\/span> 60000\r\n    max.in.flight.requests.per.connection =<\/span> 5\r\n    max.request.size =<\/span> 1048576\r\n    metadata.max.age.ms =<\/span> 300000\r\n    metric.reporters =<\/span> []<\/span>\r\n    metrics.num.samples =<\/span> 2\r\n    metrics.recording.level =<\/span> INFO\r\n    metrics.sample.window.ms =<\/span> 30000\r\n    partitioner.class =<\/span> class org.apache.kafka.clients.producer.internals.DefaultPartitioner\r\n    receive.buffer.bytes =<\/span> 32768\r\n    reconnect.backoff.max.ms =<\/span> 1000\r\n    reconnect.backoff.ms =<\/span> 50\r\n    request.timeout.ms =<\/span> 30000\r\n    retries =<\/span> 0\r\n    retry.backoff.ms =<\/span> 100\r\n    sasl.client.callback.handler.class =<\/span> null\r\n    sasl.jaas.config =<\/span> null\r\n    sasl.kerberos.kinit.cmd =<\/span> \/usr\/bin\/kinit\r\n    sasl.kerberos.min.time.before.relogin =<\/span> 60000\r\n    sasl.kerberos.service.name =<\/span> null\r\n    sasl.kerberos.ticket.renew.jitter =<\/span> 0.05\r\n    sasl.kerberos.ticket.renew.window.factor =<\/span> 0.8\r\n    sasl.login.callback.handler.class =<\/span> null\r\n    sasl.login.class =<\/span> null\r\n    sasl.login.refresh.buffer.seconds =<\/span> 300\r\n    sasl.login.refresh.min.period.seconds =<\/span> 60\r\n    sasl.login.refresh.window.factor =<\/span> 0.8\r\n    sasl.login.refresh.window.jitter =<\/span> 0.05\r\n    sasl.mechanism =<\/span> GSSAPI\r\n    security.protocol =<\/span> PLAINTEXT\r\n    send.buffer.bytes =<\/span> 131072\r\n    ssl.cipher.suites =<\/span> null\r\n    ssl.enabled.protocols =<\/span> [<\/span>TLSv1.2, TLSv1.1, TLSv1]\r\n    ssl.endpoint.identification.algorithm =<\/span> https\r\n    ssl.key.password =<\/span> null\r\n    ssl.keymanager.algorithm =<\/span> SunX509\r\n    ssl.keystore.location =<\/span> null\r\n    ssl.keystore.password =<\/span> null\r\n    ssl.keystore.type =<\/span> JKS\r\n    ssl.protocol =<\/span> TLS\r\n    ssl.provider =<\/span> null\r\n    ssl.secure.random.implementation =<\/span> null\r\n    ssl.trustmanager.algorithm =<\/span> PKIX\r\n    ssl.truststore.location =<\/span> null\r\n    ssl.truststore.password =<\/span> null\r\n    ssl.truststore.type =<\/span> JKS\r\n    transaction.timeout.ms =<\/span> 60000\r\n    transactional.id =<\/span> null\r\n    value.serializer =<\/span> class org.apache.kafka.common.serialization.StringSerializer\r\n<\/code><\/pre>\n
\u963f\u7279\u62c9\u65af\u5bb6\u65cf\uff1a\u5361\u592b\u5361 + \u98ce\u66b4<\/h2>\n
\"image.png\"<\/div>\n
\"image.png\"<\/div>\n
\"image.png\"<\/div>\n
\"image.png\"<\/div>\n
\u963f\u7279\u62c9\u65af\u4e2d\u7684Kafka\u4e3b\u9898\u5143\u6570\u636e<\/h2>\n
\"image.png\"<\/div>\n
\u5f53\u6267\u884c\u4e24\u6b21\u300cStorm\u300d\uff1a<\/h3>\n
\u5bb6\u65cf\u8840\u8109\u7684\u5173\u7cfb\u53d8\u5bc6\u96c6…<\/p>\n
\"image.png\"<\/div>\n
\u901a\u8fc7Atlas\u548cStorm\u7684\u64cd\u4f5c\uff0cAtlas\u7684\u5143\u6570\u636e\u4f1a\u88ab\u66f4\u65b0\uff0c\u4f46\u5728\u5386\u53f2\u8bb0\u5f55\u4e2d\u4e5f\u80fd\u770b\u5230\u662f\u8c01\u8fdb\u884c\u4e86\u66f4\u65b0\u3002<\/h2>\n
\"image.png\"<\/div>\n
    \n
  • \n
      \u4e00\u756a\u4e0a\u306f\u50d5\u304cTag\u3092\u3064\u3051\u305f\u3001\u4f5c\u696d\u8005\u306fAdmin\u306e\u50d5\u3002<\/ul>\n<\/li>\n<\/ul>\n
       <\/p>\n
        \n
      • \n
          \uff12\u756a\u76ee\u306fStorm\u51e6\u7406\u3067\u751f\u6210\u3057\u305fAtlas Entry<\/ul>\n<\/li>\n<\/ul>\n
           <\/p>\n
            \uff13\u756a\u76ee\u3082Storm\u51e6\u7406\u3067\u751f\u6210\u3057\u305fAtlas Entry<\/ul>\n","protected":false},"excerpt":{"rendered":"
            \u65e5\u5fd7 \u5b9f\u884c\u30ed\u30b0[centos@zzeng-hdp-1 ~\/sandbox\/crosscomponent_dem […]<\/p>\n","protected":false},"author":3,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-46930","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"\n\u5229\u7528Storm\u5904\u7406Kafka\u4e3b\u9898\uff0c\u5e76\u901a\u8fc7Apache Atlas\u663e\u793aLineage\u7684\u5185\u5bb9 - Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/\u5229\u7528storm\u5904\u7406kafka\u4e3b\u9898\uff0c\u5e76\u901a\u8fc7apache-atlas\u663e\u793alineage\u7684\u5185\u5bb9\u3002\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u5229\u7528Storm\u5904\u7406Kafka\u4e3b\u9898\uff0c\u5e76\u901a\u8fc7Apache Atlas\u663e\u793aLineage\u7684\u5185\u5bb9\" \/>\n<meta property=\"og:description\" content=\"\u65e5\u5fd7 \u5b9f\u884c\u30ed\u30b0[centos@zzeng-hdp-1 ~\/sandbox\/crosscomponent_dem […]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/\u5229\u7528storm\u5904\u7406kafka\u4e3b\u9898\uff0c\u5e76\u901a\u8fc7apache-atlas\u663e\u793alineage\u7684\u5185\u5bb9\u3002\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2023-09-08T10:49:41+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-04-28T23:05:13+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7baa913a08637a699fa8\/7-0.png\" \/>\n<meta name=\"author\" content=\"\u97f5, \u79d1\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u97f5, \u79d1\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"24 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%88%a9%e7%94%a8storm%e5%a4%84%e7%90%86kafka%e4%b8%bb%e9%a2%98%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87apache-atlas%e6%98%be%e7%a4%balineage%e7%9a%84%e5%86%85%e5%ae%b9%e3%80%82\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%88%a9%e7%94%a8storm%e5%a4%84%e7%90%86kafka%e4%b8%bb%e9%a2%98%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87apache-atlas%e6%98%be%e7%a4%balineage%e7%9a%84%e5%86%85%e5%ae%b9%e3%80%82\/\",\"name\":\"\u5229\u7528Storm\u5904\u7406Kafka\u4e3b\u9898\uff0c\u5e76\u901a\u8fc7Apache Atlas\u663e\u793aLineage\u7684\u5185\u5bb9 - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2023-09-08T10:49:41+00:00\",\"dateModified\":\"2024-04-28T23:05:13+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%88%a9%e7%94%a8storm%e5%a4%84%e7%90%86kafka%e4%b8%bb%e9%a2%98%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87apache-atlas%e6%98%be%e7%a4%balineage%e7%9a%84%e5%86%85%e5%ae%b9%e3%80%82\/#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%88%a9%e7%94%a8storm%e5%a4%84%e7%90%86kafka%e4%b8%bb%e9%a2%98%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87apache-atlas%e6%98%be%e7%a4%balineage%e7%9a%84%e5%86%85%e5%ae%b9%e3%80%82\/\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%88%a9%e7%94%a8storm%e5%a4%84%e7%90%86kafka%e4%b8%bb%e9%a2%98%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87apache-atlas%e6%98%be%e7%a4%balineage%e7%9a%84%e5%86%85%e5%ae%b9%e3%80%82\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.silicloud.com\/zh\/blog\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u5229\u7528Storm\u5904\u7406Kafka\u4e3b\u9898\uff0c\u5e76\u901a\u8fc7Apache Atlas\u663e\u793aLineage\u7684\u5185\u5bb9\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e\",\"name\":\"\u97f5, \u79d1\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g\",\"caption\":\"\u97f5, \u79d1\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/yunke\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%88%a9%e7%94%a8storm%e5%a4%84%e7%90%86kafka%e4%b8%bb%e9%a2%98%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87apache-atlas%e6%98%be%e7%a4%balineage%e7%9a%84%e5%86%85%e5%ae%b9%e3%80%82\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"\u5229\u7528Storm\u5904\u7406Kafka\u4e3b\u9898\uff0c\u5e76\u901a\u8fc7Apache Atlas\u663e\u793aLineage\u7684\u5185\u5bb9 - Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/\u5229\u7528storm\u5904\u7406kafka\u4e3b\u9898\uff0c\u5e76\u901a\u8fc7apache-atlas\u663e\u793alineage\u7684\u5185\u5bb9\u3002\/","og_locale":"zh_CN","og_type":"article","og_title":"\u5229\u7528Storm\u5904\u7406Kafka\u4e3b\u9898\uff0c\u5e76\u901a\u8fc7Apache Atlas\u663e\u793aLineage\u7684\u5185\u5bb9","og_description":"\u65e5\u5fd7 \u5b9f\u884c\u30ed\u30b0[centos@zzeng-hdp-1 ~\/sandbox\/crosscomponent_dem […]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/\u5229\u7528storm\u5904\u7406kafka\u4e3b\u9898\uff0c\u5e76\u901a\u8fc7apache-atlas\u663e\u793alineage\u7684\u5185\u5bb9\u3002\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2023-09-08T10:49:41+00:00","article_modified_time":"2024-04-28T23:05:13+00:00","og_image":[{"url":"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7baa913a08637a699fa8\/7-0.png"}],"author":"\u97f5, \u79d1","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u97f5, \u79d1","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"24 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%88%a9%e7%94%a8storm%e5%a4%84%e7%90%86kafka%e4%b8%bb%e9%a2%98%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87apache-atlas%e6%98%be%e7%a4%balineage%e7%9a%84%e5%86%85%e5%ae%b9%e3%80%82\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%88%a9%e7%94%a8storm%e5%a4%84%e7%90%86kafka%e4%b8%bb%e9%a2%98%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87apache-atlas%e6%98%be%e7%a4%balineage%e7%9a%84%e5%86%85%e5%ae%b9%e3%80%82\/","name":"\u5229\u7528Storm\u5904\u7406Kafka\u4e3b\u9898\uff0c\u5e76\u901a\u8fc7Apache Atlas\u663e\u793aLineage\u7684\u5185\u5bb9 - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2023-09-08T10:49:41+00:00","dateModified":"2024-04-28T23:05:13+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e"},"breadcrumb":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%88%a9%e7%94%a8storm%e5%a4%84%e7%90%86kafka%e4%b8%bb%e9%a2%98%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87apache-atlas%e6%98%be%e7%a4%balineage%e7%9a%84%e5%86%85%e5%ae%b9%e3%80%82\/#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/%e5%88%a9%e7%94%a8storm%e5%a4%84%e7%90%86kafka%e4%b8%bb%e9%a2%98%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87apache-atlas%e6%98%be%e7%a4%balineage%e7%9a%84%e5%86%85%e5%ae%b9%e3%80%82\/"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%88%a9%e7%94%a8storm%e5%a4%84%e7%90%86kafka%e4%b8%bb%e9%a2%98%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87apache-atlas%e6%98%be%e7%a4%balineage%e7%9a%84%e5%86%85%e5%ae%b9%e3%80%82\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.silicloud.com\/zh\/blog\/"},{"@type":"ListItem","position":2,"name":"\u5229\u7528Storm\u5904\u7406Kafka\u4e3b\u9898\uff0c\u5e76\u901a\u8fc7Apache Atlas\u663e\u793aLineage\u7684\u5185\u5bb9"}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e","name":"\u97f5, \u79d1","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g","caption":"\u97f5, \u79d1"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/yunke\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%88%a9%e7%94%a8storm%e5%a4%84%e7%90%86kafka%e4%b8%bb%e9%a2%98%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87apache-atlas%e6%98%be%e7%a4%balineage%e7%9a%84%e5%86%85%e5%ae%b9%e3%80%82\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46930","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/3"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=46930"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46930\/revisions"}],"predecessor-version":[{"id":83773,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46930\/revisions\/83773"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=46930"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=46930"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=46930"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}