File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
apps/threat-protection-backend/src/main/java/com/akto/threat/protection Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change 4
4
import com .akto .threat .protection .utils .KafkaUtils ;
5
5
import com .mongodb .ConnectionString ;
6
6
import com .mongodb .ReadPreference ;
7
+ import com .mongodb .WriteConcern ;
7
8
import com .mongodb .client .MongoClient ;
8
9
9
10
public class Main {
@@ -15,7 +16,7 @@ public static void main(String[] args) throws Exception {
15
16
MongoClient threatProtectionMongo =
16
17
DaoInit .createMongoClient (
17
18
new ConnectionString (System .getenv ("AKTO_THREAT_PROTECTION_MONGO_CONN" )),
18
- ReadPreference .secondary ());
19
+ ReadPreference .secondary (), WriteConcern . ACKNOWLEDGED );
19
20
String initProducer = System .getenv ("INIT_KAFKA_PRODUCER" );
20
21
if (initProducer != null && initProducer .equalsIgnoreCase ("true" )) {
21
22
KafkaUtils .initKafkaProducer ();
You can’t perform that action at this time.
0 commit comments