[jira] [Created] (KAFKA-6793) Unnecessary warning log message
Anna O created KAFKA-6793: - Summary: Unnecessary warning log message Key: KAFKA-6793 URL: https://issues.apache.org/jira/browse/KAFKA-6793 Project: Kafka Issue Type: Bug Components: streams Affects Versions: 1.1.0 Reporter: Anna O When upgraded KafkaStreams from 0.11.0.2 to 1.1.0 the following warning log started to appear: level: WARN logger: org.apache.kafka.clients.consumer.ConsumerConfig message: The configuration 'admin.retries' was supplied but isn't a known config. The config is not explicitly supplied to the streams. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (KAFKA-6825) DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG is private
Anna O created KAFKA-6825: - Summary: DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG is private Key: KAFKA-6825 URL: https://issues.apache.org/jira/browse/KAFKA-6825 Project: Kafka Issue Type: Bug Components: streams Affects Versions: 1.1.0 Reporter: Anna O org.apache.kafka.streams.StreamsConfig DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG constant is private. Should be public. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (KAFKA-7108) "Exactly-once" stream breaks production exception handler contract
Anna O created KAFKA-7108: - Summary: "Exactly-once" stream breaks production exception handler contract Key: KAFKA-7108 URL: https://issues.apache.org/jira/browse/KAFKA-7108 Project: Kafka Issue Type: Bug Components: streams Affects Versions: 1.1.0 Reporter: Anna O I have a stream configured with "default.production.exception.handler" that is supposed to log the error and continue. When I set "processing.guarantee" to "exactly_once" it appeared that retryable NotEnoughReplicasException that passed the production exception handler was rethrown by the TransactionManager wrapped with KafkaException and terminated the stream thread: _org.apache.kafka.common.KafkaException: Cannot execute transactional method because we are in an error stateat org.apache.kafka.clients.producer.internals.TransactionManager.maybeFailWithError(TransactionManager.java:784) ~[kafka-clients-1.1.0.jar:?]_ _at org.apache.kafka.clients.producer.internals.TransactionManager.sendOffsetsToTransaction(TransactionManager.java:250) ~[kafka-clients-1.1.0.jar:?]_ _at org.apache.kafka.clients.producer.KafkaProducer.sendOffsetsToTransaction(KafkaProducer.java:617) ~[kafka-clients-1.1.0.jar:?]_ _at org.apache.kafka.streams.processor.internals.StreamTask.commitOffsets(StreamTask.java:357) ~[kafka-streams-1.1.0.jar:?]_ _at org.apache.kafka.streams.processor.internals.StreamTask.access$000(StreamTask.java:53) ~[kafka-streams-1.1.0.jar:?]_ _at org.apache.kafka.streams.processor.internals.StreamTask$1.run(StreamTask.java:316) ~[kafka-streams-1.1.0.jar:?]_ _at org.apache.kafka.streams.processor.internals.StreamsMetricsImpl.measureLatencyNs(StreamsMetricsImpl.java:208) ~[kafka-streams-1.1.0.jar:?]_ _at org.apache.kafka.streams.processor.internals.StreamTask.commit(StreamTask.java:307) ~[kafka-streams-1.1.0.jar:?]_ _at org.apache.kafka.streams.processor.internals.StreamTask.commit(StreamTask.java:297) ~[kafka-streams-1.1.0.jar:?]_ _at org.apache.kafka.streams.processor.internals.AssignedTasks$1.apply(AssignedTasks.java:67) ~[kafka-streams-1.1.0.jar:?]_ _at org.apache.kafka.streams.processor.internals.AssignedTasks.applyToRunningTasks(AssignedTasks.java:357) [kafka-streams-1.1.0.jar:?]_ _at org.apache.kafka.streams.processor.internals.AssignedTasks.commit(AssignedTasks.java:347) [kafka-streams-1.1.0.jar:?]_ _at org.apache.kafka.streams.processor.internals.TaskManager.commitAll(TaskManager.java:403) [kafka-streams-1.1.0.jar:?]_ _at org.apache.kafka.streams.processor.internals.StreamThread.maybeCommit(StreamThread.java:994) [kafka-streams-1.1.0.jar:?]_ _at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:811) [kafka-streams-1.1.0.jar:?]_ _at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:750) [kafka-streams-1.1.0.jar:?]_ _at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:720) [kafka-streams-1.1.0.jar:?]_ _Caused by: org.apache.kafka.common.errors.NotEnoughReplicasException: Messages are rejected since there are fewer in-sync replicas than required._ -- This message was sent by Atlassian JIRA (v7.6.3#76005)