----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/73049/ -----------------------------------------------------------
(Updated Dec. 1, 2020, 4:16 p.m.) Review request for atlas, Ashutosh Mestry, Jayendra Parab, Madhan Neethiraj, and Sarath Subramanian. Summary (updated) ----------------- ATLAS-4043: Atlas import-kafka.sh does not import "__consumer_offsets" topic 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. Diffs ----- common/src/main/java/org/apache/atlas/utils/KafkaUtils.java 7a397b19b Diff: https://reviews.apache.org/r/73049/diff/1/ Testing ------- Manual testing done. Thanks, Deep Singh