[jira] [Created] (KAFKA-8400) Do not update follower replica state if the log read failed

Jason Gustafson created KAFKA-8400: -- Summary: Do not update follower replica state if the log read failed Key: KAFKA-8400 URL: https://issues.apache.org/jira/browse/KAFKA-8400 Project: Kafka

[jira] [Commented] (KAFKA-8399) Add back `internal.leave.group.on.close` config for KStreams

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

[jira] [Created] (KAFKA-8399) Add back `internal.leave.group.on.close` config for KStreams

Boyang Chen created KAFKA-8399: -- Summary: Add back `internal.leave.group.on.close` config for KStreams Key: KAFKA-8399 URL: https://issues.apache.org/jira/browse/KAFKA-8399 Project: Kafka Issue

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

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

[jira] [Comment Edited] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

[ https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844388#comment-16844388 ] Jason Gustafson edited comment on KAFKA-6029 at 5/20/19 11:36 PM: -

[jira] [Commented] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

[ https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844388#comment-16844388 ] Jason Gustafson commented on KAFKA-6029: I think we can actually resolve this as

[jira] [Created] (KAFKA-8398) NPE when unmapping files after moving log directories using AlterReplicaLogDirs

Vikas Singh created KAFKA-8398: -- Summary: NPE when unmapping files after moving log directories using AlterReplicaLogDirs Key: KAFKA-8398 URL: https://issues.apache.org/jira/browse/KAFKA-8398 Project: Ka

[jira] [Created] (KAFKA-8397) Add pre-registration feature for static membership

Boyang Chen created KAFKA-8397: -- Summary: Add pre-registration feature for static membership Key: KAFKA-8397 URL: https://issues.apache.org/jira/browse/KAFKA-8397 Project: Kafka Issue Type: Impr

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844297#comment-16844297 ] John Roesler commented on KAFKA-8377: - Oh, it also looks like the value getter suppli

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844290#comment-16844290 ] John Roesler commented on KAFKA-8377: - I happened to be looking at the TransformValue

[jira] [Commented] (KAFKA-8347) Choose next record to process by timestamp

[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844233#comment-16844233 ] Sophie Blee-Goldman commented on KAFKA-8347: Oh I missed the RC1 email but yo

[jira] [Updated] (KAFKA-8347) Choose next record to process by timestamp

[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8347: --- Fix Version/s: (was: 2.2.1) 2.2.2 > Choose next record to proc

[jira] [Commented] (KAFKA-8265) Connect Client Config Override policy

[ https://issues.apache.org/jira/browse/KAFKA-8265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844218#comment-16844218 ] ASF GitHub Bot commented on KAFKA-8265: --- rhauch commented on pull request #6755: KA

[jira] [Resolved] (KAFKA-5476) Implement a system test that creates network partitions

[ https://issues.apache.org/jira/browse/KAFKA-5476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-5476. Resolution: Duplicate > Implement a system test that creates network partitions > -

[jira] [Updated] (KAFKA-8074) Create SSL keystore/truststore only once for each node in system tests

[ https://issues.apache.org/jira/browse/KAFKA-8074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-8074: --- Fix Version/s: (was: 2.3.0) > Create SSL keystore/truststore only once for each node in s

[jira] [Updated] (KAFKA-3190) KafkaProducer should not invoke callback in send()

[ https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-3190: --- Fix Version/s: (was: 2.3.0) 2.4.0 Moving to 2.4.0, since 2.3 seems unl

[jira] [Updated] (KAFKA-3333) Alternative Partitioner to Support "Always Round-Robin" partitioning

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-: --- Fix Version/s: (was: 2.3.0) 2.4.0 Moving this out of 2.3 and into 2.4,

[jira] [Resolved] (KAFKA-7921) Instable KafkaStreamsTest

[ https://issues.apache.org/jira/browse/KAFKA-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-7921. Resolution: Fixed Let's re-open this if we see another failure. > Instable KafkaStreamsTes

[jira] [Commented] (KAFKA-7991) Add StreamsUpgradeTest for 2.2 release

[ https://issues.apache.org/jira/browse/KAFKA-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844188#comment-16844188 ] Colin P. McCabe commented on KAFKA-7991: Do you still want to do this in 2.3? >

[jira] [Updated] (KAFKA-8385) Fix leader election RPC for all partition so that only partition that had elections are returned

[ https://issues.apache.org/jira/browse/KAFKA-8385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-8385: -- Fix Version/s: (was: 2.3.0) > Fix leader election RPC for all parti

[jira] [Updated] (KAFKA-8384) Write integration tests for leader election command

[ https://issues.apache.org/jira/browse/KAFKA-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-8384: -- Fix Version/s: (was: 2.3.0) > Write integration tests for leader el

[jira] [Updated] (KAFKA-8383) Write integration test for electLeaders

[ https://issues.apache.org/jira/browse/KAFKA-8383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-8383: -- Fix Version/s: (was: 2.3.0) > Write integration test for electLeade

[jira] [Updated] (KAFKA-8265) Connect Client Config Override policy

[ https://issues.apache.org/jira/browse/KAFKA-8265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-8265: --- Affects Version/s: (was: 2.3.0) Fix Version/s: (was: 2.3.0) > Connect Client

[jira] [Assigned] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe reassigned KAFKA-7500: -- Assignee: (was: Colin P. McCabe) Fix Version/s: (was: 2.3.0)

[jira] [Updated] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-7500: --- Reviewer: (was: Colin P. McCabe) > MirrorMaker 2.0 (KIP-382) > - >

[jira] [Comment Edited] (KAFKA-8207) StickyPartitionAssignor for KStream

[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844168#comment-16844168 ] Boyang Chen edited comment on KAFKA-8207 at 5/20/19 6:01 PM: -

[jira] [Commented] (KAFKA-8207) StickyPartitionAssignor for KStream

[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844168#comment-16844168 ] Boyang Chen commented on KAFKA-8207: Hey [~neeraj.bhatt] thank you for your interest!

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

[ https://issues.apache.org/jira/browse/KAFKA-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8284: --- Fix Version/s: 2.3.0 > Enable static membership on KStream > --- > >

[jira] [Updated] (KAFKA-8220) Avoid kicking out members through rebalance timeout

[ https://issues.apache.org/jira/browse/KAFKA-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8220: --- Fix Version/s: 2.3.0 > Avoid kicking out members through rebalance timeout >

[jira] [Updated] (KAFKA-7862) Modify JoinGroup logic to incorporate group.instance.id change

[ https://issues.apache.org/jira/browse/KAFKA-7862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-7862: --- Fix Version/s: 2.3.0 > Modify JoinGroup logic to incorporate group.instance.id change > -

[jira] [Updated] (KAFKA-8225) Handle conflicting static member id

[ https://issues.apache.org/jira/browse/KAFKA-8225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8225: --- Fix Version/s: 2.3.0 > Handle conflicting static member id > --- > >

[jira] [Resolved] (KAFKA-7992) Add a server start time metric

[ https://issues.apache.org/jira/browse/KAFKA-7992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-7992. Resolution: Fixed Fix Version/s: 2.3.0 > Add a server start time metric > --

[jira] [Resolved] (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 ] Jason Gustafson resolved KAFKA-8316. Resolution: Fixed > Remove deprecated usage of Slf4jRequestLog, SslContextFactory > ---

[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=16844128#comment-16844128 ] ASF GitHub Bot commented on KAFKA-8316: --- hachikuji commented on pull request #6668:

[jira] [Commented] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist

[ https://issues.apache.org/jira/browse/KAFKA-7633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844109#comment-16844109 ] Muzeeb commented on KAFKA-7633: --- Which version ([https://hub.docker.com/r/confluentinc/cp-k

[jira] [Updated] (KAFKA-8364) Avoid decompression of record when validate record at server in the scene of inPlaceAssignment .

[ https://issues.apache.org/jira/browse/KAFKA-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8364: - Description: We do performance testing about Kafka server in specific scenarios .We build a kafk

[jira] [Updated] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8377: - Labels: newbie++ (was: ) > KTable#transformValue might lead to incorrect result in joins > -

[jira] [Commented] (KAFKA-4600) Consumer proceeds on when ConsumerRebalanceListener fails

[ https://issues.apache.org/jira/browse/KAFKA-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844103#comment-16844103 ] Guozhang Wang commented on KAFKA-4600: -- [~braedon] Thanks for your feedbacks. The re

[jira] [Commented] (KAFKA-8365) Protocol and consumer support for follower fetching

[ https://issues.apache.org/jira/browse/KAFKA-8365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844104#comment-16844104 ] ASF GitHub Bot commented on KAFKA-8365: --- mumrah commented on pull request #6775: Mi

[jira] [Commented] (KAFKA-8396) Clean up Transformer API

[ https://issues.apache.org/jira/browse/KAFKA-8396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844095#comment-16844095 ] Guozhang Wang commented on KAFKA-8396: -- I like the idea; About the further cleanup

[jira] [Updated] (KAFKA-8396) Clean up Transformer API

[ https://issues.apache.org/jira/browse/KAFKA-8396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8396: - Labels: needs-kip user-experience (was: needs-kip) > Clean up Transformer API >

[jira] [Updated] (KAFKA-8371) Remove ReplicaManager dependence from Partition

[ https://issues.apache.org/jira/browse/KAFKA-8371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8371: - Labels: tech-debt (was: ) > Remove ReplicaManager dependence from Partition > --

[jira] [Resolved] (KAFKA-7358) Alternative Partitioner to Support "Always Round-Robin" Selection

[ https://issues.apache.org/jira/browse/KAFKA-7358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7358. Resolution: Duplicate > Alternative Partitioner to Support "Always Round-Robin" Selection >

[jira] [Updated] (KAFKA-8373) Add group.instance.id field into Sync/Heartbeat/OffsetCommit protocols

[ https://issues.apache.org/jira/browse/KAFKA-8373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8373: - Fix Version/s: 2.3.0 > Add group.instance.id field into Sync/Heartbeat/OffsetCommit protocols >

[jira] [Updated] (KAFKA-8396) Clean up Transformer API

[ https://issues.apache.org/jira/browse/KAFKA-8396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8396: --- Labels: needs-kip (was: ) > Clean up Transformer API > > >

[jira] [Commented] (KAFKA-8367) Non-heap memory leak in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844075#comment-16844075 ] Guozhang Wang commented on KAFKA-8367: -- Could creating the {{new BloomFilter()}} in

[jira] [Resolved] (KAFKA-8381) SSL factory for inter-broker listener is broken

[ https://issues.apache.org/jira/browse/KAFKA-8381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8381. --- Resolution: Fixed Reviewer: Manikumar > SSL factory for inter-broker listener is broken

[jira] [Created] (KAFKA-8396) Clean up Transformer API

John Roesler created KAFKA-8396: --- Summary: Clean up Transformer API Key: KAFKA-8396 URL: https://issues.apache.org/jira/browse/KAFKA-8396 Project: Kafka Issue Type: Improvement Compon

[jira] [Commented] (KAFKA-8395) Add an ability to backup log segment files on truncation

[ https://issues.apache.org/jira/browse/KAFKA-8395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844064#comment-16844064 ] ASF GitHub Bot commented on KAFKA-8395: --- axiak commented on pull request #6772: KAF

[jira] [Commented] (KAFKA-8207) StickyPartitionAssignor for KStream

[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844062#comment-16844062 ] Matthias J. Sax commented on KAFKA-8207: I actually just talked to [~bchen225242]

[jira] [Created] (KAFKA-8395) Add an ability to backup log segment files on truncation

Michael Axiak created KAFKA-8395: Summary: Add an ability to backup log segment files on truncation Key: KAFKA-8395 URL: https://issues.apache.org/jira/browse/KAFKA-8395 Project: Kafka Issue

[jira] [Updated] (KAFKA-8395) Add an ability to backup log segment files on truncation

[ https://issues.apache.org/jira/browse/KAFKA-8395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Axiak updated KAFKA-8395: - Flags: Patch > Add an ability to backup log segment files on truncation > ---

[jira] [Resolved] (KAFKA-8376) Flaky test ClientAuthenticationFailureTest.testTransactionalProducerWithInvalidCredentials test.

[ https://issues.apache.org/jira/browse/KAFKA-8376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8376. Resolution: Fixed > Flaky test > ClientAuthenticationFailureTest.testTransactionalProducer

[jira] [Commented] (KAFKA-8381) SSL factory for inter-broker listener is broken

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

[jira] [Commented] (KAFKA-3333) Alternative Partitioner to Support "Always Round-Robin" partitioning

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

[jira] [Updated] (KAFKA-3333) Alternative Partitioner to Support "Always Round-Robin" partitioning

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna updated KAFKA-: Description: ** Please Look into KAFKA-7358 for the official description **   The [DefaultPartitioner|ht

[jira] [Assigned] (KAFKA-3333) Alternative Partitioner to Support "Always Round-Robin" partitioning

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna reassigned KAFKA-: --- Assignee: M. Manna Fix Version/s: 2.3.0 Affects Version/s: (was: 0.10.0.0)

[jira] [Updated] (KAFKA-3333) Alternative Partitioner to Support "Always Round-Robin" assignment

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna updated KAFKA-: Summary: Alternative Partitioner to Support "Always Round-Robin" assignment (was: Client Partitioner - Rou

[jira] [Updated] (KAFKA-3333) Alternative Partitioner to Support "Always Round-Robin" partitioning

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna updated KAFKA-: Summary: Alternative Partitioner to Support "Always Round-Robin" partitioning (was: Alternative Partitione

[jira] [Comment Edited] (KAFKA-7358) Alternative Partitioner to Support "Always Round-Robin" Selection

[ https://issues.apache.org/jira/browse/KAFKA-7358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843951#comment-16843951 ] M. Manna edited comment on KAFKA-7358 at 5/20/19 2:24 PM: -- [~mjs

[jira] [Commented] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843982#comment-16843982 ] Bill Bejeck commented on KAFKA-8290: cherry-picked to 2.2, 2.1 and 2.0 > Streams Not

[jira] [Updated] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8290: --- Fix Version/s: 2.0.2 > Streams Not Closing Fenced Producer On Task Close > --

[jira] [Updated] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8290: --- Fix Version/s: 2.2.2 2.1.2 2.3.0 > Streams Not Closing Fenced P

[jira] [Commented] (KAFKA-7358) Alternative Partitioner to Support "Always Round-Robin" Selection

[ https://issues.apache.org/jira/browse/KAFKA-7358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843951#comment-16843951 ] M. Manna commented on KAFKA-7358: - [~mjsax] Yes - looks like my pull request effort was n

[jira] [Updated] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8290: --- Affects Version/s: 2.0.0 2.1.0 2.2.0 > Streams Not Clos

[jira] [Commented] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

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

[jira] [Created] (KAFKA-8394) Cannot Start a build with New Gradle Version

M. Manna created KAFKA-8394: --- Summary: Cannot Start a build with New Gradle Version Key: KAFKA-8394 URL: https://issues.apache.org/jira/browse/KAFKA-8394 Project: Kafka Issue Type: Bug Co

[jira] [Created] (KAFKA-8393) Kafka Connect: Kafka Connect: could not get type for name org.osgi.framework.BundleListener on Windows

Loïc created KAFKA-8393: --- Summary: Kafka Connect: Kafka Connect: could not get type for name org.osgi.framework.BundleListener on Windows Key: KAFKA-8393 URL: https://issues.apache.org/jira/browse/KAFKA-8393 Pr

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843739#comment-16843739 ] Matthias J. Sax commented on KAFKA-7994: I am personally not convinced, that usin

[jira] [Commented] (KAFKA-8207) StickyPartitionAssignor for KStream

[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843733#comment-16843733 ] Matthias J. Sax commented on KAFKA-8207: I think that's correct. [~bchen225242] w