[jira] [Created] (KAFKA-7108) "Exactly-once" stream breaks production exception handler contract

[Anna O (JIRA)]

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)

[jira] [Created] (KAFKA-6825) DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG is private

[Anna O (JIRA)]

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-6793) Unnecessary warning log message

[Anna O (JIRA)]

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)