nheron/kie-platform
nheron/kie-platform
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Merge pull request #224 from pymma/kafka

Browse source 
better error management
This commit is contained in:
Nicolas Héron 2021-02-19 17:51:41 +01:00 • committed by GitHub
commit 6d493b0688
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
drools-framework-business-proxy-parent/drools-framework-business-proxy-app/src/main/java/org/chtijbug/drools/proxy/DroolsBusinessProxyServer.java
View file

@ -118,7 +118,7 @@ public class DroolsBusinessProxyServer {
ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
JsonSerializer.class); JsonSerializer.class);
configProps.put( configProps.put(
ProducerConfig.MAX_REQUEST_SIZE_CONFIG, 4655826); ProducerConfig.MAX_REQUEST_SIZE_CONFIG, 41943040);
if (activateSsl) { if (activateSsl) {
configProps.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, SecurityProtocol.SSL.name); configProps.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, SecurityProtocol.SSL.name);

4
drools-framework-business-proxy-parent/drools-framework-business-proxy-app/src/main/java/org/chtijbug/drools/proxy/service/RuleService.java
View file

@ -60,8 +60,10 @@ public class RuleService {
kafkaTemplateLogging.send(KafkaTopicConstants.LOGING_TOPIC,chtijbugObjectRequest); kafkaTemplateLogging.send(KafkaTopicConstants.LOGING_TOPIC,chtijbugObjectRequest);
}catch (Exception e){ }catch (Exception e){
logger.error(" kafkaTemplateLogging.send",e); logger.error(" kafkaTemplateLogging.send",e);
} }finally {
return chtijbutObjectResponse.getObjectRequest(); return chtijbutObjectResponse.getObjectRequest();
} }
} }
}