|
|
|
@ -113,17 +113,17 @@ import static org.apache.kafka.common.config.ConfigDef.ValidString.in;
@@ -113,17 +113,17 @@ import static org.apache.kafka.common.config.ConfigDef.ValidString.in;
|
|
|
|
|
* |
|
|
|
|
* By default, Kafka Streams does not allow users to overwrite the following properties (Streams setting shown in parentheses): |
|
|
|
|
* <ul> |
|
|
|
|
* <li>{@link ConsumerConfig#GROUP_ID_CONFIG "group.id"} (<application.id>) - Streams client will always use the application ID a consumer group ID</li> |
|
|
|
|
* <li>{@link ConsumerConfig#ENABLE_AUTO_COMMIT_CONFIG "enable.auto.commit"} (false) - Streams client will always disable/turn off auto committing</li> |
|
|
|
|
* <li>{@link ConsumerConfig#PARTITION_ASSIGNMENT_STRATEGY_CONFIG "partition.assignment.strategy"} (<code>StreamsPartitionAssignor</code>) - Streams client will always use its own partition assignor</li> |
|
|
|
|
* </ul> |
|
|
|
|
* |
|
|
|
|
* If {@link #PROCESSING_GUARANTEE_CONFIG "processing.guarantee"} is set to {@link #EXACTLY_ONCE "exactly_once"}, Kafka Streams does not allow users to overwrite the following properties (Streams setting shown in parentheses): |
|
|
|
|
* <ul> |
|
|
|
|
* <li>{@link ConsumerConfig#ISOLATION_LEVEL_CONFIG "isolation.level"} (read_committed) - Consumers will always read committed data only</li> |
|
|
|
|
* <li>{@link ProducerConfig#ENABLE_IDEMPOTENCE_CONFIG "enable.idempotence"} (true) - Producer will always have idempotency enabled</li> |
|
|
|
|
* <li>{@link ProducerConfig#MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION "max.in.flight.requests.per.connection"} (5) - Producer will always have one in-flight request per connection</li> |
|
|
|
|
* </ul> |
|
|
|
|
* |
|
|
|
|
* |
|
|
|
|
* @see KafkaStreams#KafkaStreams(org.apache.kafka.streams.Topology, Properties) |
|
|
|
|
* @see ConsumerConfig |
|
|
|
|
* @see ProducerConfig |
|
|
|
|