Major Description
AtlasTagSource.commitToKafka() is hard coded to commit offset to topic ATLAS_ENTITIES. The topic to which entity events are sent from Atlas and received by Ranger Tagsync is determined by atlas.notification.entities.topic.name property in atlas-application.properties file. By default, it is ATLAS_ENTITIES but some might configure it to a different name in which case Tagsync would be committing offset to the wrong topic.