RANGER-4349: AtlasTagSource.commitToKafka() should commit the offset …

…to the topic from which the event came from.

Signed-off-by: szymonorz <szyorz@proton.me>
Signed-off-by: Ramesh Mani <rmani@apache.org>

tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/AtlasTagSource.java

@@ -316,7 +316,7 @@ private void commitToKafka(AtlasKafkaMessage<EntityNotification> messageToCommit
 			int  partitionId   = messageToCommit.getPartition();
 
 			if (offsetOfLastMessageCommittedToKafka < messageOffset) {
-				TopicPartition partition = new TopicPartition("ATLAS_ENTITIES", partitionId);
+				TopicPartition partition = new TopicPartition(messageToCommit.getTopic(), partitionId);
 				try {
 					if (LOG.isDebugEnabled()) {
 						LOG.debug("Committing message with offset:[" + messageOffset + "] to Kafka");