[jira] [Commented] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832325#comment-16832325 ] Andrew commented on KAFKA-8315: --- The fudge factor is the \{windowstore.changelog.additional

[jira] [Commented] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition

[ https://issues.apache.org/jira/browse/KAFKA-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832406#comment-16832406 ] Rajini Sivaram commented on KAFKA-7697: --- [~jwesteen] [~nsnmurthy] Thank you! The de

[jira] [Commented] (KAFKA-8316) Remove deprecated usage of Slf4jRequestLog, SslContextFactory

[ https://issues.apache.org/jira/browse/KAFKA-8316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832415#comment-16832415 ] ASF GitHub Bot commented on KAFKA-8316: --- dongjinleekr commented on pull request #66

[jira] [Assigned] (KAFKA-8316) Remove deprecated usage of Slf4jRequestLog, SslContextFactory

[ https://issues.apache.org/jira/browse/KAFKA-8316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8316: -- Assignee: Lee Dongjin > Remove deprecated usage of Slf4jRequestLog, SslContextFactory > --

[jira] [Assigned] (KAFKA-8308) Update jetty for security vulnerability CVE-2019-10241

[ https://issues.apache.org/jira/browse/KAFKA-8308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8308: -- Assignee: Lee Dongjin > Update jetty for security vulnerability CVE-2019-10241 > -

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832325#comment-16832325 ] Andrew edited comment on KAFKA-8315 at 5/3/19 1:03 PM: --- The fudge f

[jira] [Commented] (KAFKA-8238) Log how many bytes and messages were read from __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832523#comment-16832523 ] ASF GitHub Bot commented on KAFKA-8238: --- vamossagar12 commented on pull request #66

[jira] [Commented] (KAFKA-8240) Source.equals() can fail with NPE

[ https://issues.apache.org/jira/browse/KAFKA-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832539#comment-16832539 ] ASF GitHub Bot commented on KAFKA-8240: --- bbejeck commented on pull request #6589: K

[jira] [Commented] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832543#comment-16832543 ] Andrew commented on KAFKA-8315: --- [~vvcephei] Ive been struggling with this today. * I h

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832543#comment-16832543 ] Andrew edited comment on KAFKA-8315 at 5/3/19 2:38 PM: --- [~vvcephei]

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832543#comment-16832543 ] Andrew edited comment on KAFKA-8315 at 5/3/19 2:38 PM: --- [~vvcephei]

[jira] [Created] (KAFKA-8318) Session Window Aggregations generate an extra tombstone

John Roesler created KAFKA-8318: --- Summary: Session Window Aggregations generate an extra tombstone Key: KAFKA-8318 URL: https://issues.apache.org/jira/browse/KAFKA-8318 Project: Kafka Issue Typ

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832543#comment-16832543 ] Andrew edited comment on KAFKA-8315 at 5/3/19 3:03 PM: --- [~vvcephei]

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832543#comment-16832543 ] Andrew edited comment on KAFKA-8315 at 5/3/19 3:05 PM: --- [~vvcephei]

[jira] [Updated] (KAFKA-8289) KTable, Long> can't be suppressed

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-8289: Fix Version/s: (was: 2.2.2) 2.2.1 > KTable, Long> can't be suppressed > ---

[jira] [Commented] (KAFKA-8289) KTable, Long> can't be suppressed

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832575#comment-16832575 ] John Roesler commented on KAFKA-8289: - [~vahid], can you explain why this critical bu

[jira] [Commented] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832577#comment-16832577 ] Andrew commented on KAFKA-8315: --- [~vvcephei] Update I ran using grace = 20D and I see recor

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832577#comment-16832577 ] Andrew edited comment on KAFKA-8315 at 5/3/19 3:26 PM: --- [~vvcephei]

[jira] [Created] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory

Bill Bejeck created KAFKA-8319: -- Summary: Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory Key: KAFKA-8319 URL: https://issues.apache.org/jira/browse/KAFKA-8319 Project: Kafka

[jira] [Commented] (KAFKA-8289) KTable, Long> can't be suppressed

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832582#comment-16832582 ] Vahid Hashemian commented on KAFKA-8289: [~vvcephei] Since, according to your ear

[jira] [Commented] (KAFKA-8240) Source.equals() can fail with NPE

[ https://issues.apache.org/jira/browse/KAFKA-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832585#comment-16832585 ] Vahid Hashemian commented on KAFKA-8240: [~mjsax] I see the PR is merged. Can thi

[jira] [Comment Edited] (KAFKA-8289) KTable, Long> can't be suppressed

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832582#comment-16832582 ] Vahid Hashemian edited comment on KAFKA-8289 at 5/3/19 3:39 PM: ---

[jira] [Commented] (KAFKA-8254) Suppress incorrectly passes a null topic to the serdes

[ https://issues.apache.org/jira/browse/KAFKA-8254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832593#comment-16832593 ] John Roesler commented on KAFKA-8254: - 2.2.1 has been proposed: https://cwiki.apache

[jira] [Commented] (KAFKA-8204) Streams may flush state stores in the incorrect order

[ https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832592#comment-16832592 ] John Roesler commented on KAFKA-8204: - 2.2.1 has been proposed: https://cwiki.apache

[jira] [Resolved] (KAFKA-8240) Source.equals() can fail with NPE

[ https://issues.apache.org/jira/browse/KAFKA-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8240. Resolution: Fixed > Source.equals() can fail with NPE > - > >

[jira] [Commented] (KAFKA-8289) KTable, Long> can't be suppressed

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832653#comment-16832653 ] John Roesler commented on KAFKA-8289: - Last I heard [~bbejeck] was working on merging

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832577#comment-16832577 ] Andrew edited comment on KAFKA-8315 at 5/3/19 5:32 PM: --- [~vvcephei]

[jira] [Commented] (KAFKA-8289) KTable, Long> can't be suppressed

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832685#comment-16832685 ] ASF GitHub Bot commented on KAFKA-8289: --- vvcephei commented on pull request #6670:

[jira] [Resolved] (KAFKA-8308) Update jetty for security vulnerability CVE-2019-10241

[ https://issues.apache.org/jira/browse/KAFKA-8308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-8308. Resolution: Fixed Assignee: Ismael Juma (was: Lee Dongjin) Fix Version/s: 2.3.0 Th

[jira] [Commented] (KAFKA-8289) KTable, Long> can't be suppressed

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832703#comment-16832703 ] ASF GitHub Bot commented on KAFKA-8289: --- vvcephei commented on pull request #6671:

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832577#comment-16832577 ] Andrew edited comment on KAFKA-8315 at 5/3/19 6:21 PM: --- [~vvcephei]

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832577#comment-16832577 ] Andrew edited comment on KAFKA-8315 at 5/3/19 6:34 PM: --- [~vvcephei]

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832577#comment-16832577 ] Andrew edited comment on KAFKA-8315 at 5/3/19 6:54 PM: --- [~vvcephei]

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832577#comment-16832577 ] Andrew edited comment on KAFKA-8315 at 5/3/19 6:54 PM: --- [~vvcephei]

[jira] [Reopened] (KAFKA-8240) Source.equals() can fail with NPE

[ https://issues.apache.org/jira/browse/KAFKA-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reopened KAFKA-8240: This needs to get cherry-picked back to 2.2 and 2.1 so reopening.  I'll resolve once that happens. >

[jira] [Commented] (KAFKA-8289) KTable, Long> can't be suppressed

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832801#comment-16832801 ] ASF GitHub Bot commented on KAFKA-8289: --- bbejeck commented on pull request #6670: K

[jira] [Commented] (KAFKA-8284) Enable static membership on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832849#comment-16832849 ] ASF GitHub Bot commented on KAFKA-8284: --- abbccdda commented on pull request #6673:

[jira] [Created] (KAFKA-8320) Connect Error handling is using the RetriableException from common package

Magesh kumar Nandakumar created KAFKA-8320: -- Summary: Connect Error handling is using the RetriableException from common package Key: KAFKA-8320 URL: https://issues.apache.org/jira/browse/KAFKA-8320

[jira] [Commented] (KAFKA-8289) KTable, Long> can't be suppressed

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832869#comment-16832869 ] John Roesler commented on KAFKA-8289: - Hi [~vahid], the fix has been merged to 2.2 .

[jira] [Created] (KAFKA-8321) Flaky Test kafka.server.DynamicConfigTest.shouldFailWhenChangingClientIdUnknownConfig

Bill Bejeck created KAFKA-8321: -- Summary: Flaky Test kafka.server.DynamicConfigTest.shouldFailWhenChangingClientIdUnknownConfig Key: KAFKA-8321 URL: https://issues.apache.org/jira/browse/KAFKA-8321 Proje

[jira] [Updated] (KAFKA-8320) Connect Error handling is using the RetriableException from common package

[ https://issues.apache.org/jira/browse/KAFKA-8320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Magesh kumar Nandakumar updated KAFKA-8320: --- Description: When a SourceConnector throws  org.apache.kafka.connect.errors.

[jira] [Updated] (KAFKA-8320) Connect Error handling is using the RetriableException from common package

[ https://issues.apache.org/jira/browse/KAFKA-8320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Magesh kumar Nandakumar updated KAFKA-8320: --- Description: When a SourceConnector throws  org.apache.kafka.connect.errors.

[jira] [Commented] (KAFKA-8320) Connect Error handling is using the RetriableException from common package

[ https://issues.apache.org/jira/browse/KAFKA-8320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832886#comment-16832886 ] ASF GitHub Bot commented on KAFKA-8320: --- mageshn commented on pull request #6675: K

[jira] [Created] (KAFKA-8322) Flaky test: SslTransportLayerTest.testListenerConfigOverride

Dhruvil Shah created KAFKA-8322: --- Summary: Flaky test: SslTransportLayerTest.testListenerConfigOverride Key: KAFKA-8322 URL: https://issues.apache.org/jira/browse/KAFKA-8322 Project: Kafka Iss

[jira] [Updated] (KAFKA-8322) Flaky test: SslTransportLayerTest.testListenerConfigOverride

[ https://issues.apache.org/jira/browse/KAFKA-8322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah updated KAFKA-8322: Description: java.lang.AssertionError: expected: but was: at org.junit.Assert.fail(Assert.java:89)

[jira] [Created] (KAFKA-8323) Memory leak of BloomFilter Rocks object

Sophie Blee-Goldman created KAFKA-8323: -- Summary: Memory leak of BloomFilter Rocks object Key: KAFKA-8323 URL: https://issues.apache.org/jira/browse/KAFKA-8323 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-8323) Memory leak of BloomFilter Rocks object

[ https://issues.apache.org/jira/browse/KAFKA-8323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8323: --- Affects Version/s: (was: 2.2.1) (was: 2.3.0)

[jira] [Created] (KAFKA-8324) User constructed RocksObjects leak memory

Sophie Blee-Goldman created KAFKA-8324: -- Summary: User constructed RocksObjects leak memory Key: KAFKA-8324 URL: https://issues.apache.org/jira/browse/KAFKA-8324 Project: Kafka Issue Typ

[jira] [Comment Edited] (KAFKA-7946) Flaky Test DeleteConsumerGroupsTest#testDeleteNonEmptyGroup

[ https://issues.apache.org/jira/browse/KAFKA-7946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832206#comment-16832206 ] Vahid Hashemian edited comment on KAFKA-7946 at 5/3/19 11:42 PM: --

[jira] [Resolved] (KAFKA-7946) Flaky Test DeleteConsumerGroupsTest#testDeleteNonEmptyGroup

[ https://issues.apache.org/jira/browse/KAFKA-7946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-7946. Resolution: Fixed Fix Version/s: 2.2.1 > Flaky Test DeleteConsumerGroupsTest#testDel

[jira] [Commented] (KAFKA-8323) Memory leak of BloomFilter Rocks object

[ https://issues.apache.org/jira/browse/KAFKA-8323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832934#comment-16832934 ] ASF GitHub Bot commented on KAFKA-8323: --- bbejeck commented on pull request #6672: K

[jira] [Resolved] (KAFKA-8323) Memory leak of BloomFilter Rocks object

[ https://issues.apache.org/jira/browse/KAFKA-8323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8323. Resolution: Fixed cherry-picked to 2.2 as well > Memory leak of BloomFilter Rocks object > ---

[jira] [Commented] (KAFKA-8323) Memory leak of BloomFilter Rocks object

[ https://issues.apache.org/jira/browse/KAFKA-8323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832941#comment-16832941 ] ASF GitHub Bot commented on KAFKA-8323: --- ableegoldman commented on pull request #66

[jira] [Updated] (KAFKA-8324) User constructed RocksObjects leak memory

[ https://issues.apache.org/jira/browse/KAFKA-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8324: --- Description: Some of the RocksDB options a user can set when extending RocksDBConfigS

[jira] [Resolved] (KAFKA-8289) KTable, Long> can't be suppressed

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-8289. Resolution: Fixed > KTable, Long> can't be suppressed > --