[jira] [Created] (KAFKA-10376) TimeWindowedDeserializer does not deserialize the end timestamp of time window aggregate message keys.

2020-08-08 Thread B R (Jira)
B R created KAFKA-10376: --- Summary: TimeWindowedDeserializer does not deserialize the end timestamp of time window aggregate message keys. Key: KAFKA-10376 URL: https://issues.apache.org/jira/browse/KAFKA-10376

[jira] [Updated] (KAFKA-10370) WorkerSinkTask: IllegalStateException cased by consumer.seek(tp, offsets) when (tp, offsets) are supplied by WorkerSinkTaskContext

2020-08-08 Thread Ning Zhang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ning Zhang updated KAFKA-10370: --- Description: In [WorkerSinkTask.java|https://github.com/apache/kafka/blob/trunk/connect/runtime/src

[jira] [Updated] (KAFKA-10370) WorkerSinkTask: IllegalStateException cased by consumer.seek(tp, offsets) when (tp, offsets) are supplied by WorkerSinkTaskContext

2020-08-08 Thread Ning Zhang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ning Zhang updated KAFKA-10370: --- Description: In [WorkerSinkTask.java|https://github.com/apache/kafka/blob/trunk/connect/runtime/src

[jira] [Updated] (KAFKA-10370) WorkerSinkTask: IllegalStateException cased by consumer.seek(tp, offsets) when (tp, offsets) are supplied by WorkerSinkTaskContext

2020-08-08 Thread Ning Zhang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ning Zhang updated KAFKA-10370: --- Description: In WorkerSinkTask.java, when we want the consumer to consume from certain offsets, rat

[jira] [Commented] (KAFKA-10009) Add method for getting last record offset in kafka partition

2020-08-08 Thread Werner Daehn (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173671#comment-17173671 ] Werner Daehn commented on KAFKA-10009: -- What would be needed is either * endOffset

[jira] [Updated] (KAFKA-10009) Add method for getting last record offset in kafka partition

2020-08-08 Thread Werner Daehn (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Werner Daehn updated KAFKA-10009: - Priority: Major (was: Minor) > Add method for getting last record offset in kafka partition > -

[jira] [Commented] (KAFKA-10009) Add method for getting last record offset in kafka partition

2020-08-08 Thread Werner Daehn (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173661#comment-17173661 ] Werner Daehn commented on KAFKA-10009: -- It is actually worse than that. There coul

[jira] [Updated] (KAFKA-10373) Kafka Reassign Partition is stuck with Java OutOfMemory error

2020-08-08 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-10373: -- Component/s: (was: KafkaConnect) core > Kafka Reassign Partition is stuck

[jira] [Updated] (KAFKA-10375) Restore consumer fails with SSL handshake fail exception

2020-08-08 Thread Levani Kokhreidze (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-10375: -- Attachment: stacktrace.txt > Restore consumer fails with SSL handshake fail exception

[jira] [Updated] (KAFKA-10375) Restore consumer fails with SSL handshake fail exception

2020-08-08 Thread Levani Kokhreidze (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-10375: -- Attachment: (was: stacktrace.txt) > Restore consumer fails with SSL handshake fail

[jira] [Created] (KAFKA-10375) Restore consumer fails with SSL handshake fail exception

2020-08-08 Thread Levani Kokhreidze (Jira)
Levani Kokhreidze created KAFKA-10375: - Summary: Restore consumer fails with SSL handshake fail exception Key: KAFKA-10375 URL: https://issues.apache.org/jira/browse/KAFKA-10375 Project: Kafka

[jira] [Commented] (KAFKA-9659) Kafka Streams / Consumer configured for static membership fails on "fatal exception: group.instance.id gets fenced"

2020-08-08 Thread Levani Kokhreidze (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173636#comment-17173636 ] Levani Kokhreidze commented on KAFKA-9659: -- Hi [~guozhang] just wanted to let yo

[GitHub] [kafka] jeqo commented on pull request #9137: KAFKA-9929: Support reverse iterator on KeyValueStore

2020-08-08 Thread GitBox
jeqo commented on pull request #9137: URL: https://github.com/apache/kafka/pull/9137#issuecomment-670850075 cc @ableegoldman This PR is ready for review, covering related feedback from #8976 This is an automated messa

[jira] [Resolved] (KAFKA-10352) Error while reading checkpoint file /tmp/kafka-logs/cleaner-offset-checkpoint (kafka.server.LogDirFailureChannel)

2020-08-08 Thread Seongbae Chang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seongbae Chang resolved KAFKA-10352. Resolution: Resolved > Error while reading checkpoint file /tmp/kafka-logs/cleaner-offset-

[jira] [Commented] (KAFKA-10352) Error while reading checkpoint file /tmp/kafka-logs/cleaner-offset-checkpoint (kafka.server.LogDirFailureChannel)

2020-08-08 Thread Seongbae Chang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173595#comment-17173595 ] Seongbae Chang commented on KAFKA-10352: Thank you for your answer, [~dongjin]!