We have a big cluster, after integrate atlas with our hive servers, lots of notification messages in Kafka are not processed because the event process is too slow.
We increase atlas.notification.hook.numthreads but nothing changed. Then we read the code, noticed that the kafka consumer is hard code to 1 thread. My question is: 1. why it is hard code as 1, is there limitation in atlas that there could be only one thread can update data 2. can we increase thread count.
