[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=16837765#comment-16837765 ] Sophie Blee-Goldman commented on KAFKA-8315: [~the4thamigo_uk] After I directed you to check

[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=16837764#comment-16837764 ] ASF GitHub Bot commented on KAFKA-8347: --- ableegoldman commented on pull request #6719: KAFKA-8347:

[jira] [Commented] (KAFKA-7206) Enable batching in FindCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837729#comment-16837729 ] Guozhang Wang commented on KAFKA-7206: -- [~sagarrao] I think [~shung] has tried to implemented this

[jira] [Updated] (KAFKA-8346) Improve replica fetcher behavior in handling partition failures

[ https://issues.apache.org/jira/browse/KAFKA-8346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aishwarya Gune updated KAFKA-8346: -- Description: The replica fetcher thread terminates in case one of the partitions being

[jira] [Updated] (KAFKA-8346) Improve replica fetcher behavior in handling partition failures

[ https://issues.apache.org/jira/browse/KAFKA-8346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aishwarya Gune updated KAFKA-8346: -- Description: The replica fetcher thread terminates in case one of the partitions being

[jira] [Assigned] (KAFKA-8346) Improve replica fetcher behavior in handling partition failures

[ https://issues.apache.org/jira/browse/KAFKA-8346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aishwarya Gune reassigned KAFKA-8346: - Assignee: Aishwarya Gune > Improve replica fetcher behavior in handling partition

[jira] [Updated] (KAFKA-8352) Connect System Tests are failing with 404

[ https://issues.apache.org/jira/browse/KAFKA-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8352: - Reviewer: Randall Hauch > Connect System Tests are failing with 404 >

[jira] [Resolved] (KAFKA-8352) Connect System Tests are failing with 404

[ https://issues.apache.org/jira/browse/KAFKA-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8352. -- Resolution: Fixed Thanks, [~mageshn]! > Connect System Tests are failing with 404 >

[jira] [Commented] (KAFKA-8352) Connect System Tests are failing with 404

[ https://issues.apache.org/jira/browse/KAFKA-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837682#comment-16837682 ] ASF GitHub Bot commented on KAFKA-8352: --- rhauch commented on pull request #6713: KAFKA-8352 : Fix

[jira] [Updated] (KAFKA-8346) Improve replica fetcher behavior in handling partition failures

[ https://issues.apache.org/jira/browse/KAFKA-8346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aishwarya Gune updated KAFKA-8346: -- External issue URL: (was: https://github.com/apache/kafka/pull/6716) > Improve replica

[jira] [Updated] (KAFKA-8346) Improve replica fetcher behavior in handling partition failures

[ https://issues.apache.org/jira/browse/KAFKA-8346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aishwarya Gune updated KAFKA-8346: -- Description: The replica fetcher thread terminates in case one of the partitions being

[jira] [Updated] (KAFKA-8346) Improve replica fetcher behavior in handling partition failures

[ https://issues.apache.org/jira/browse/KAFKA-8346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aishwarya Gune updated KAFKA-8346: -- External issue URL: https://github.com/apache/kafka/pull/6716 > Improve replica fetcher

[jira] [Updated] (KAFKA-8224) Add static member id into Subscription Info for better rebalance behavior

[ https://issues.apache.org/jira/browse/KAFKA-8224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8224: --- Issue Type: Improvement (was: Sub-task) Parent: (was: KAFKA-7018) > Add static member

[jira] [Created] (KAFKA-8355) Add static membership to Range assignor

Boyang Chen created KAFKA-8355: -- Summary: Add static membership to Range assignor Key: KAFKA-8355 URL: https://issues.apache.org/jira/browse/KAFKA-8355 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-8356) Add static membership to Round Robin assignor

Boyang Chen created KAFKA-8356: -- Summary: Add static membership to Round Robin assignor Key: KAFKA-8356 URL: https://issues.apache.org/jira/browse/KAFKA-8356 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837664#comment-16837664 ] ASF GitHub Bot commented on KAFKA-8335: --- hachikuji commented on pull request #6715: KAFKA-8335;

[jira] [Created] (KAFKA-8354) Replace SyncGroup request/response with automated protocol

Boyang Chen created KAFKA-8354: -- Summary: Replace SyncGroup request/response with automated protocol Key: KAFKA-8354 URL: https://issues.apache.org/jira/browse/KAFKA-8354 Project: Kafka Issue

[jira] [Commented] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837653#comment-16837653 ] Guozhang Wang commented on KAFKA-8335: -- [~boquan] [~weichu] Thanks for reporting this issue. Jason

[jira] [Commented] (KAFKA-8221) Augment LeaveGroupRequest to batch operation

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

[jira] [Created] (KAFKA-8353) org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms after enabling SASL PLAINTEXT authentication

goutham created KAFKA-8353: -- Summary: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 6 ms after enabling SASL PLAINTEXT authentication Key: KAFKA-8353 URL:

[jira] [Updated] (KAFKA-8305) AdminClient should support creating topics with default partitions and replication factor

[ https://issues.apache.org/jira/browse/KAFKA-8305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Almog Gavra updated KAFKA-8305: --- Summary: AdminClient should support creating topics with default partitions and replication factor

[jira] [Commented] (KAFKA-8305) AdminClient should support creating topics with default partitions and replication factor

[ https://issues.apache.org/jira/browse/KAFKA-8305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837631#comment-16837631 ] Almog Gavra commented on KAFKA-8305: Approved 

[jira] [Commented] (KAFKA-6789) Add retry logic in AdminClient requests

[ https://issues.apache.org/jira/browse/KAFKA-6789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837620#comment-16837620 ] Vahid Hashemian commented on KAFKA-6789: Updated. > Add retry logic in AdminClient requests >

[jira] [Updated] (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 ] Vahid Hashemian updated KAFKA-8240: --- Fix Version/s: (was: 2.2.2) 2.2.1 > Source.equals() can fail with NPE

[jira] [Updated] (KAFKA-6789) Add retry logic in AdminClient requests

[ https://issues.apache.org/jira/browse/KAFKA-6789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-6789: --- Fix Version/s: (was: 2.2.2) 2.2.1 > Add retry logic in AdminClient

[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=16837618#comment-16837618 ] Vahid Hashemian commented on KAFKA-8240: [~mjsax] Sorry I missed it. Updated. Feel free to update

[jira] [Updated] (KAFKA-8352) Connect System Tests are failing with 404

[ https://issues.apache.org/jira/browse/KAFKA-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8352: - Fix Version/s: 2.2.1 2.1.2 2.0.2 > Connect System Tests

[jira] [Updated] (KAFKA-8352) Connect System Tests are failing with 404

[ https://issues.apache.org/jira/browse/KAFKA-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8352: - Affects Version/s: 2.2.1 2.1.2 2.0.2 > Connect

[jira] [Commented] (KAFKA-6789) Add retry logic in AdminClient requests

[ https://issues.apache.org/jira/browse/KAFKA-6789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837616#comment-16837616 ] Matthias J. Sax commented on KAFKA-6789: [~vahid] Does this need a fix version update from 2.2.2

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

[ https://issues.apache.org/jira/browse/KAFKA-7946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7946: --- Fix Version/s: (was: 2.2.2) > Flaky Test

[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=16837611#comment-16837611 ] Matthias J. Sax commented on KAFKA-8240: [~vahid] Are you rolling a new RC? You update the other

[jira] [Updated] (KAFKA-8051) remove KafkaMbean when network close

[ https://issues.apache.org/jira/browse/KAFKA-8051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8051: --- Fix Version/s: (was: 2.2.2) > remove KafkaMbean when network close >

[jira] [Updated] (KAFKA-8049) remove KafkaMbean when network close

[ https://issues.apache.org/jira/browse/KAFKA-8049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8049: --- Fix Version/s: (was: 2.2.2) > remove KafkaMbean when network close >

[jira] [Updated] (KAFKA-7978) Flaky Test SaslSslAdminClientIntegrationTest#testConsumerGroups

[ https://issues.apache.org/jira/browse/KAFKA-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7978: --- Fix Version/s: (was: 2.2.2) (was: 2.3.0) > Flaky Test

[jira] [Updated] (KAFKA-8050) remove KafkaMbean when network close

[ https://issues.apache.org/jira/browse/KAFKA-8050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8050: --- Fix Version/s: (was: 2.2.2) > remove KafkaMbean when network close >

[jira] [Updated] (KAFKA-8048) remove KafkaMbean when network close

[ https://issues.apache.org/jira/browse/KAFKA-8048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8048: --- Fix Version/s: (was: 2.2.2) > remove KafkaMbean when network close >

[jira] [Updated] (KAFKA-8346) Improve replica fetcher behavior in handling partition failures

[ https://issues.apache.org/jira/browse/KAFKA-8346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aishwarya Gune updated KAFKA-8346: -- Description: The replica fetcher thread terminates in case one of the partitions being

[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 ] Magesh kumar Nandakumar updated KAFKA-8265: --- Affects Version/s: 2.3.0 Priority: Major (was: Minor)

[jira] [Commented] (KAFKA-8352) Connect System Tests are failing with 404

[ https://issues.apache.org/jira/browse/KAFKA-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837590#comment-16837590 ] ASF GitHub Bot commented on KAFKA-8352: --- mageshn commented on pull request #6713: KAFKA-8352 : Fix

[jira] [Created] (KAFKA-8352) Connect System Tests are failing with 404

Magesh kumar Nandakumar created KAFKA-8352: -- Summary: Connect System Tests are failing with 404 Key: KAFKA-8352 URL: https://issues.apache.org/jira/browse/KAFKA-8352 Project: Kafka

[jira] [Updated] (KAFKA-8348) Document of kafkaStreams improvement

[ https://issues.apache.org/jira/browse/KAFKA-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-8348: --- Fix Version/s: (was: 2.2.2) 2.2.1 > Document of kafkaStreams

[jira] [Resolved] (KAFKA-8339) At-least-once delivery guarantee seemingly not met due to async commit / produce failure race condition

[ https://issues.apache.org/jira/browse/KAFKA-8339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tdp resolved KAFKA-8339. Resolution: Not A Problem Marking as resolved. This is working as expected from the streams side and the bug is

[jira] [Commented] (KAFKA-8247) Duplicate error handling in kafka-server-start.sh and actual Kafka class

[ https://issues.apache.org/jira/browse/KAFKA-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837510#comment-16837510 ] Sönke Liebau commented on KAFKA-8247: - I've experimented a bit with this, I removed all those checks

[jira] [Updated] (KAFKA-8286) KIP-460 Admin Leader Election RPC

[ https://issues.apache.org/jira/browse/KAFKA-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-8286: -- Description: Tracking issue for implementing KIP-460. Tasks: # [Done]

[jira] [Resolved] (KAFKA-7858) Replace JoinGroup request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-7858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-7858. Resolution: Fixed > Replace JoinGroup request/response with automated protocol >

[jira] [Created] (KAFKA-8351) Log cleaner must handle transactions spanning multiple segments

Jason Gustafson created KAFKA-8351: -- Summary: Log cleaner must handle transactions spanning multiple segments Key: KAFKA-8351 URL: https://issues.apache.org/jira/browse/KAFKA-8351 Project: Kafka

[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=16837349#comment-16837349 ] John Roesler commented on KAFKA-8204: - FYI, 2.2.1 RC0 vote is in progress.

[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=16837351#comment-16837351 ] John Roesler commented on KAFKA-8289: - FYI, 2.2.1 RC0 vote is in progress.

[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=16837350#comment-16837350 ] John Roesler commented on KAFKA-8254: - FYI, 2.2.1 RC0 vote is in progress.

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837348#comment-16837348 ] John Roesler commented on KAFKA-7895: - FYI, 2.2.1 RC0 vote is in progress.

[jira] [Commented] (KAFKA-8348) Document of kafkaStreams improvement

[ https://issues.apache.org/jira/browse/KAFKA-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837314#comment-16837314 ] Vahid Hashemian commented on KAFKA-8348: Sounds good [~mjsax]. > Document of kafkaStreams

[jira] [Assigned] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8187: -- Assignee: Bill Bejeck (was: Matthias J. Sax) > State store record loss across multiple

[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=16837303#comment-16837303 ] John Roesler commented on KAFKA-8315: - Ah, yes. My apologies. I was mistaken about the PartitionGroup

[jira] [Commented] (KAFKA-8313) KafkaStreams state not being updated properly after shutdown

[ https://issues.apache.org/jira/browse/KAFKA-8313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837209#comment-16837209 ] Eric commented on KAFKA-8313: - Thanks [~guozhang] for the follow up.  Is there a place I can grab nightly

[jira] [Updated] (KAFKA-8348) Document of kafkaStreams improvement

[ https://issues.apache.org/jira/browse/KAFKA-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8348: --- Reviewer: (was: Matthias J. Sax) > Document of kafkaStreams improvement >

[jira] [Commented] (KAFKA-8348) Document of kafkaStreams improvement

[ https://issues.apache.org/jira/browse/KAFKA-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837131#comment-16837131 ] Matthias J. Sax commented on KAFKA-8348: [~vahid] I marked this as fixed version 2.2.2 – if we

[jira] [Updated] (KAFKA-8348) Document of kafkaStreams improvement

[ https://issues.apache.org/jira/browse/KAFKA-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8348: --- Fix Version/s: 2.2.2 2.1.2 2.3.0

[jira] [Resolved] (KAFKA-8348) Document of kafkaStreams improvement

[ https://issues.apache.org/jira/browse/KAFKA-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lifei Chen resolved KAFKA-8348. --- Resolution: Fixed > Document of kafkaStreams improvement > > >

[jira] [Updated] (KAFKA-8348) Document of kafkaStreams improvement

[ https://issues.apache.org/jira/browse/KAFKA-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8348: --- Affects Version/s: 1.0.0 1.0.1 1.0.2

[jira] [Commented] (KAFKA-8348) Document of kafkaStreams improvement

[ https://issues.apache.org/jira/browse/KAFKA-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837118#comment-16837118 ] ASF GitHub Bot commented on KAFKA-8348: --- mjsax commented on pull request #6707: KAFKA-8348 document

[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=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:48 AM: [~ableegoldman]

[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=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:47 AM: [~ableegoldman]

[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=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:43 AM: [~ableegoldman]

[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=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:42 AM: [~ableegoldman]

[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=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:42 AM: [~ableegoldman]

[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=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:42 AM: [~ableegoldman]

[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=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:40 AM: [~ableegoldman]

[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=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:32 AM: [~ableegoldman]

[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=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:31 AM: [~ableegoldman]

[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=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:27 AM: [~ableegoldman]

[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=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:26 AM: [~ableegoldman] Can I

[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=16837086#comment-16837086 ] Andrew commented on KAFKA-8315: --- [~ableegoldman] Can I sanity check my understanding here. From what I can

[jira] [Updated] (KAFKA-8350) Splitting batches should consider topic-level message size

[ https://issues.apache.org/jira/browse/KAFKA-8350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-8350: -- Description: Currently, producers do the batch splitting based on the batch size. However, the split will

[jira] [Created] (KAFKA-8350) Splitting batches should consider topic-level message size

huxihx created KAFKA-8350: - Summary: Splitting batches should consider topic-level message size Key: KAFKA-8350 URL: https://issues.apache.org/jira/browse/KAFKA-8350 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-8349) Add Windows batch files corresponding to kafka-delete-records.sh and kafka-log-dirs.sh

[ https://issues.apache.org/jira/browse/KAFKA-8349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837011#comment-16837011 ] ASF GitHub Bot commented on KAFKA-8349: --- sekikn commented on pull request #6709: KAFKA-8349. Add

[jira] [Created] (KAFKA-8349) Add Windows batch files corresponding to kafka-delete-records.sh and kafka-log-dirs.sh

Kengo Seki created KAFKA-8349: - Summary: Add Windows batch files corresponding to kafka-delete-records.sh and kafka-log-dirs.sh Key: KAFKA-8349 URL: https://issues.apache.org/jira/browse/KAFKA-8349

[jira] [Commented] (KAFKA-8348) Document of kafkaStreams improvement

[ https://issues.apache.org/jira/browse/KAFKA-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836924#comment-16836924 ] Lifei Chen commented on KAFKA-8348: --- Hi [~mjsax],  I am starting to read and contribute to kafka

[jira] [Updated] (KAFKA-8348) Document of kafkaStreams improvement

[ https://issues.apache.org/jira/browse/KAFKA-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lifei Chen updated KAFKA-8348: -- Reviewer: Matthias J. Sax > Document of kafkaStreams improvement >

[jira] [Commented] (KAFKA-8348) Document of kafkaStreams improvement

[ https://issues.apache.org/jira/browse/KAFKA-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836916#comment-16836916 ] ASF GitHub Bot commented on KAFKA-8348: --- hustclf commented on pull request #6707: KAFKA-8348

[jira] [Created] (KAFKA-8348) Document of kafkaStreams improvement

Lifei Chen created KAFKA-8348: - Summary: Document of kafkaStreams improvement Key: KAFKA-8348 URL: https://issues.apache.org/jira/browse/KAFKA-8348 Project: Kafka Issue Type: Improvement