----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/73049/#review222259 -----------------------------------------------------------
Fix it, then Ship it! common/src/main/java/org/apache/atlas/utils/KafkaUtils.java Lines 61 (patched) <https://reviews.apache.org/r/73049/#comment311326> consider renaming to: "atlas.hook.kafka.import.internal.topics" => "atlas.kafka.bridge.enable.internal.topics.import" - Sarath Subramanian On Dec. 1, 2020, 10:02 a.m., Deep Singh wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/73049/ > ----------------------------------------------------------- > > (Updated Dec. 1, 2020, 10:02 a.m.) > > > Review request for atlas, Ashutosh Mestry, Jayendra Parab, Madhan Neethiraj, > and Sarath Subramanian. > > > Bugs: ATLAS-4043 > https://issues.apache.org/jira/browse/ATLAS-4043 > > > Repository: atlas > > > Description > ------- > > Recently changes were made to remove dependency on zookeeper. This bug got > introduced as regression. Kafka AdminClient is now used to get the list of > existing topics. The API removes the topic which are internal to Kafka. > With this fix I have introduced an API option to include the internal topic > as well. > The option is configuration driven. > One need to set atlas.hook.kafka.import.internal.topics=true in the atlas > application properties(/etc/atlas/conf/atlas-application.properties) > > > Diffs > ----- > > common/src/main/java/org/apache/atlas/utils/KafkaUtils.java 7a397b19b > > > Diff: https://reviews.apache.org/r/73049/diff/2/ > > > Testing > ------- > > Manual testing done. > > > Thanks, > > Deep Singh > >
