<div class="markdown-block">Em chào anh ạ. Hiện tại em đang làm 1 project kết nối giữa kafka và mongodb, em đang thực hiện như sau: , application.yml</div><div class="markdown-block">spring:</div><div class="markdown-block">mongo:</div><div class="markdown-block">enabled: false</div><div class="markdown-block">hosts:</div><ul class="markdown-list"><li class="markdown-list-item"><div class="markdown-list-item-content"> host: 192.168.101.43</div><div class="markdown-block">port: 27017</div></li></ul><div class="markdown-block">username: chatbot</div><div class="markdown-block">password: chatbot@vtcc</div><div class="markdown-block">authSource: chatbot_platform</div><div class="markdown-block">kafka:</div><div class="markdown-block">bootstrap:</div><div class="markdown-block">servers: 192.168.101.43:9092, 192.168.101.69:9092</div><div class="markdown-block">topic:</div><div class="markdown-block">name: notification</div><div class="markdown-block">orderName: order</div><div class="markdown-block">topic-json:</div><div class="markdown-block">name: notification</div><div class="markdown-block">orderName: order</div><div class="markdown-block">consumer:</div><div class="markdown-block">group: myGroup</div><div class="markdown-block">orderGroup: orderGroup</div><div class="markdown-block">username: kafka</div><div class="markdown-block">password: 123456aA@</div><div class="markdown-block">, AsyncConfig</div><div class="markdown-block">@Configuration</div><div class="markdown-block">public class AsyncConfig {</div><div class="markdown-block">@Bean(name = "asyncTask")</div><div class="markdown-block">public ThreadPoolTaskExecutor asyncTask() {</div><div class="markdown-block">ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();</div><div class="markdown-block">executor.setCorePoolSize(10); // Số lượng luồng cố định</div><div class="markdown-block">executor.setMaxPoolSize(50); // Số lượng luồng tối đa</div><div class="markdown-block">executor.setQueueCapacity(100); // Số lượng tác vụ chờ trong hàng đợi</div><div class="markdown-block">executor.setThreadNamePrefix("asyncTask-");</div><div class="markdown-block">executor.setKeepAliveSeconds(60);</div><div class="markdown-block">executor.initialize();</div><div class="markdown-block">return executor;</div><div class="markdown-block">}</div><div class="markdown-block">@Bean</div>

<div class="markdown-block">Em chào anh ạ. Anh cho em hỏi, em đang có 1 project em chia thành các module nhỏ trong đó có module "common" em dùng mongo-java-driver</div><div class="markdown-block">&lt;dependency&gt;</div><div class="markdown-block">&lt;groupId&gt;org.mongodb&lt;/groupId&gt;</div><div class="markdown-block">&lt;artifactId&gt;mongo-java-driver&lt;/artifactId&gt;</div><div class="markdown-block">&lt;version&gt;&lt;/version&gt;</div><div class="markdown-block">&lt;/dependency&gt;</div><div class="markdown-block">Bây giờ ở 1 module mới em muốn dùng sang Mongo của Spring mà vẫn muốn dùng các config của common</div><div class="markdown-block">&lt;dependency&gt;</div><div class="markdown-block">&lt;groupId&gt;com.example.common&lt;/groupId&gt;</div><div class="markdown-block">&lt;artifactId&gt;common&lt;/artifactId&gt;</div><div class="markdown-block">&lt;version&gt;0.0.1-SNAPSHOT&lt;/version&gt;</div><div class="markdown-block">&lt;/dependency&gt;</div><div class="markdown-block">&lt;dependency&gt;</div><div class="markdown-block">&lt;groupId&gt;org.springframework.boot&lt;/groupId&gt;</div><div class="markdown-block">&lt;artifactId&gt;spring-boot-starter-data-mongodb&lt;/artifactId&gt;</div><div class="markdown-block">&lt;/dependency&gt;</div><div class="markdown-block">Vì tính chất không thể thay đổi ở common, vậy có cách nào có thể dùng Mongo của Spring ở module mới mà không bị conflix thư viện với mongo ở module "common" không ạ.Em cảm ơn ạ</div>

<div class="markdown-block">Em chào anh.Em đang có 1 task lấy data từ Activemq đã đưọc đọc và lưu vào Elasticsearch. Tuy nhiên em chưa có hướng để làm phần này. Anh có thể giúp em được không ạ.Em cảm ơn ạ</div>

<div class="markdown-block">Em chào anh.Em đang dùng Lookup trong MongoTemplate để join 2 collection như sau: findUsersWithDepartments() {ProjectionOperation projectionOperation = Aggregation.project().and(ConvertOperators.valueOf("userId").convertToObjectId()).as("userId");Aggregation aggregation = Aggregation.newAggregation(projectionOperation,Aggregation.lookup(departmentCollectionName, "_id","userId","departments"));AggregationResults results = mongoTemplate.aggregate(aggregation, userCollectionName, UserWithDepartment.class);return results.getMappedResults();}Vấn đề của em là "_id" kiểu dữ liệu objectId còn "userId" kiểu dữ liệu String vì vậy em cần convert về 1 kiểu dữ liệu nhưng đang gặp lỗi này: Unrecognized expression '$toObjectId'Anh đã gặp lỗi này chưa và cách khắc phục là gì ạ.Em cảm ơn ạ</div>