Aggregator processor enables an application to aggregates incoming messages into groups and release them into an output destination.
java -jar aggregator-processor-kafka-<version>.jar --aggregator.message-store-type=jdbc
Change kafka to rabbit if you want to run it against RabbitMQ.
Properties grouped by prefix:
- aggregation
-
SpEL expression for aggregation strategy. Default is collection of payloads. (Expression, default:
<none>) - correlation
-
SpEL expression for correlation key. Default to correlationId header. (Expression, default:
<none>) - group-timeout
-
SpEL expression for timeout to expiring uncompleted groups. (Expression, default:
<none>) - message-store-entity
-
Persistence message store entity: table prefix in RDBMS, collection name in MongoDb, etc. (String, default:
<none>) - message-store-type
-
Message store type. (String, default:
<none>) - release
-
SpEL expression for release strategy. Default is based on the sequenceSize header. (Expression, default:
<none>)
- authentication-database
-
Authentication database name. (String, default:
<none>) - auto-index-creation
-
Whether to enable auto-index creation. (Boolean, default:
<none>) - database
-
Database name. (String, default:
<none>) - field-naming-strategy
-
Fully qualified name of the FieldNamingStrategy to use. (Class<?>, default:
<none>) - grid-fs-database
-
<documentation missing> (String, default:
<none>) - host
-
Mongo server host. Cannot be set with URI. (String, default:
<none>) - password
-
Login password of the mongo server. Cannot be set with URI. (Character[], default:
<none>) - port
-
Mongo server port. Cannot be set with URI. (Integer, default:
<none>) - replica-set-name
-
Required replica set name for the cluster. Cannot be set with URI. (String, default:
<none>) - uri
-
Mongo database URI. Cannot be set with host, port, credentials and replica set name. (String, default:
mongodb://localhost/test) - username
-
Login user of the mongo server. Cannot be set with URI. (String, default:
<none>) - uuid-representation
-
Representation to use when converting a UUID to a BSON binary value. (UuidRepresentation, default:
java-legacy, possible values:UNSPECIFIED,STANDARD,C_SHARP_LEGACY,JAVA_LEGACY,PYTHON_LEGACY)
- continue-on-error
-
Whether to stop if an error occurs while initializing the database. (Boolean, default:
false) - data
-
Data (DML) script resource references. (List<String>, default:
<none>) - data-password
-
Password of the database to execute DML scripts (if different). (String, default:
<none>) - data-username
-
Username of the database to execute DML scripts (if different). (String, default:
<none>) - driver-class-name
-
Fully qualified name of the JDBC driver. Auto-detected based on the URL by default. (String, default:
<none>) - embedded-database-connection
-
Connection details for an embedded database. Defaults to the most suitable embedded database that is available on the classpath. (EmbeddedDatabaseConnection, default:
<none>, possible values:NONE,H2,DERBY,HSQL,HSQLDB) - generate-unique-name
-
Whether to generate a random datasource name. (Boolean, default:
true) - initialization-mode
-
Mode to apply when determining if DataSource initialization should be performed using the available DDL and DML scripts. (DataSourceInitializationMode, default:
embedded, possible values:ALWAYS,EMBEDDED,NEVER) - jndi-name
-
JNDI location of the datasource. Class, url, username and password are ignored when set. (String, default:
<none>) - name
-
Datasource name to use if "generate-unique-name" is false. Defaults to "testdb" when using an embedded database, otherwise null. (String, default:
<none>) - password
-
Login password of the database. (String, default:
<none>) - platform
-
Platform to use in the DDL or DML scripts (such as schema-${platform}.sql or data-${platform}.sql). (String, default:
all) - schema
-
Schema (DDL) script resource references. (List<String>, default:
<none>) - schema-password
-
Password of the database to execute DDL scripts (if different). (String, default:
<none>) - schema-username
-
Username of the database to execute DDL scripts (if different). (String, default:
<none>) - separator
-
Statement separator in SQL initialization scripts. (String, default:
;) - sql-script-encoding
-
SQL scripts encoding. (Charset, default:
<none>) - type
-
Fully qualified name of the connection pool implementation to use. By default, it is auto-detected from the classpath. (Class<DataSource>, default:
<none>) - url
-
JDBC URL of the database. (String, default:
<none>) - username
-
Login username of the database. (String, default:
<none>)
- features
-
Comma-separated list of features to enable. Uses the defaults of the configured version by default. (Set<Feature>, default:
[sync_delay]) - version
-
Version of Mongo to use. (String, default:
3.5.5)
- client-name
-
Client name to be set on connections with CLIENT SETNAME. (String, default:
<none>) - client-type
-
Type of client to use. By default, auto-detected according to the classpath. (ClientType, default:
<none>, possible values:LETTUCE,JEDIS) - connect-timeout
-
Connection timeout. (Duration, default:
<none>) - database
-
Database index used by the connection factory. (Integer, default:
0) - host
-
Redis server host. (String, default:
localhost) - password
-
Login password of the redis server. (String, default:
<none>) - port
-
Redis server port. (Integer, default:
6379) - ssl
-
Whether to enable SSL support. (Boolean, default:
false) - timeout
-
Read timeout. (Duration, default:
<none>) - url
-
Connection URL. Overrides host, port, and password. User is ignored. Example: redis://user:password@example.com:6379 (String, default:
<none>) - username
-
Login username of the redis server. (String, default:
<none>)