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

Merge pull request #220 from pymma/kafka

Browse source 
add max message size for kafka
This commit is contained in:
Nicolas Héron 2021-02-03 17:12:34 +01:00 • committed by GitHub
commit c6c0ff8320
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 18 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

15
docker-compose.yaml
View file

@ -331,6 +331,11 @@ services:
KAFKA_ZOOKEEPER_CONNECT: "zoo1:2181,zoo2:2182,zoo3:2183" KAFKA_ZOOKEEPER_CONNECT: "zoo1:2181,zoo2:2182,zoo3:2183"
KAFKA_BROKER_ID: 1 KAFKA_BROKER_ID: 1
KAFKA_LOG4J_LOGGERS: "kafka.controller=INFO,kafka.producer.async.DefaultEventHandler=INFO,state.change.logger=INFO" KAFKA_LOG4J_LOGGERS: "kafka.controller=INFO,kafka.producer.async.DefaultEventHandler=INFO,state.change.logger=INFO"
KAFKA_FETCH_MAX_BYTES: 5048576
KAFKA_REPLICA_FETCH_MAX_BYTES: 5048576
KAFKA_MESSAGE_MAX_BYTES: 5048576
KAFKA_PRODUCER_MAX_REQUEST_SIZE: 5048576
CONNECT_PRODUCER_MAX_REQUEST_SIZE: 5048576
volumes: volumes:
- kafka1_data:/var/lib/kafka/data - kafka1_data:/var/lib/kafka/data
depends_on: depends_on:
@ -353,6 +358,11 @@ services:
KAFKA_ZOOKEEPER_CONNECT: "zoo1:2181,zoo2:2182,zoo3:2183" KAFKA_ZOOKEEPER_CONNECT: "zoo1:2181,zoo2:2182,zoo3:2183"
KAFKA_BROKER_ID: 2 KAFKA_BROKER_ID: 2
KAFKA_LOG4J_LOGGERS: "kafka.controller=INFO,kafka.producer.async.DefaultEventHandler=INFO,state.change.logger=INFO" KAFKA_LOG4J_LOGGERS: "kafka.controller=INFO,kafka.producer.async.DefaultEventHandler=INFO,state.change.logger=INFO"
KAFKA_FETCH_MAX_BYTES: 5048576
KAFKA_REPLICA_FETCH_MAX_BYTES: 5048576
KAFKA_MESSAGE_MAX_BYTES: 5048576
KAFKA_PRODUCER_MAX_REQUEST_SIZE: 5048576
CONNECT_PRODUCER_MAX_REQUEST_SIZE: 5048576
volumes: volumes:
- kafka2_data:/var/lib/kafka/data - kafka2_data:/var/lib/kafka/data
depends_on: depends_on:
@ -375,6 +385,11 @@ services:
KAFKA_ZOOKEEPER_CONNECT: "zoo1:2181,zoo2:2182,zoo3:2183" KAFKA_ZOOKEEPER_CONNECT: "zoo1:2181,zoo2:2182,zoo3:2183"
KAFKA_BROKER_ID: 3 KAFKA_BROKER_ID: 3
KAFKA_LOG4J_LOGGERS: "kafka.controller=INFO,kafka.producer.async.DefaultEventHandler=INFO,state.change.logger=INFO" KAFKA_LOG4J_LOGGERS: "kafka.controller=INFO,kafka.producer.async.DefaultEventHandler=INFO,state.change.logger=INFO"
KAFKA_FETCH_MAX_BYTES: 5048576
KAFKA_REPLICA_FETCH_MAX_BYTES: 5048576
KAFKA_MESSAGE_MAX_BYTES: 5048576
KAFKA_PRODUCER_MAX_REQUEST_SIZE: 5048576
CONNECT_PRODUCER_MAX_REQUEST_SIZE: 5048576
volumes: volumes:
- kafka3_data:/var/lib/kafka/data - kafka3_data:/var/lib/kafka/data
depends_on: depends_on:

4
drools-framework-admin-console-parent/drools-framework-admin-console/src/main/java/org/chtijbug/drools/console/view/ActionLoggingView.java
View file

@ -50,7 +50,9 @@ public class ActionLoggingView extends VerticalLayout {
dialogPerso.getClose().setVisible(false); dialogPerso.getClose().setVisible(false);
this.uniqueID = businessTransactionPersistence.getTransactionId(); this.uniqueID = businessTransactionPersistence.getTransactionId();
this.dbID = businessTransactionPersistence.getId(); this.dbID = businessTransactionPersistence.getId();
if (this.uniqueID==null){
this.uniqueID=this.dbID;
}
title = new Label("TransactionID : " + businessTransactionPersistence.getTransactionId() + "--" + businessTransactionPersistence.getId()); title = new Label("TransactionID : " + businessTransactionPersistence.getTransactionId() + "--" + businessTransactionPersistence.getId());
title.setClassName("creation-runtime-title"); title.setClassName("creation-runtime-title");