[jira] [Commented] (KAFKA-8342) Admin tool to setup Kafka Stream topology (internal) topics

[ https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847245#comment-16847245 ] WooYoung commented on KAFKA-8342: - [~bchen225242] I`m interested in this ticket to help them to go

[jira] [Commented] (KAFKA-8424) Replace ListGroups request/response with automated protocol

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

[jira] [Commented] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847211#comment-16847211 ] Sebastiaan commented on KAFKA-8412: --- [~mjsax] yes we are using EOS. And yeah you're right, I was

[jira] [Commented] (KAFKA-8342) Admin tool to setup Kafka Stream topology (internal) topics

[ https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847174#comment-16847174 ] Boyang Chen commented on KAFKA-8342: [~clearpal7] Let me know if this sounds interesting to you. >

[jira] [Commented] (KAFKA-8311) Better consumer timeout exception handling

[ https://issues.apache.org/jira/browse/KAFKA-8311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847170#comment-16847170 ] Boyang Chen commented on KAFKA-8311: [~clearpal7] No worry, let me take a look of your fix! > Better

[jira] [Created] (KAFKA-8424) Replace ListGroups request/response with automated protocol

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

[jira] [Created] (KAFKA-8423) Update ducktape to not use deprecated APIs

Matthias J. Sax created KAFKA-8423: -- Summary: Update ducktape to not use deprecated APIs Key: KAFKA-8423 URL: https://issues.apache.org/jira/browse/KAFKA-8423 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-8404) Authorization header is not passed in Connect when forwarding REST requests

[ https://issues.apache.org/jira/browse/KAFKA-8404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota updated KAFKA-8404: - Affects Version/s: 2.0.0 > Authorization header is not passed in Connect when forwarding REST

[jira] [Created] (KAFKA-8422) Client should not use old versions of OffsetsForLeaderEpoch

Jason Gustafson created KAFKA-8422: -- Summary: Client should not use old versions of OffsetsForLeaderEpoch Key: KAFKA-8422 URL: https://issues.apache.org/jira/browse/KAFKA-8422 Project: Kafka

[jira] [Assigned] (KAFKA-8093) Fix JavaDoc markup

[ https://issues.apache.org/jira/browse/KAFKA-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrik Kleindl reassigned KAFKA-8093: - Assignee: Matthias J. Sax (was: Patrik Kleindl) > Fix JavaDoc markup >

[jira] [Resolved] (KAFKA-8093) Fix JavaDoc markup

[ https://issues.apache.org/jira/browse/KAFKA-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrik Kleindl resolved KAFKA-8093. --- Resolution: Fixed Fixed by other commits, see PR for discussion. > Fix JavaDoc markup >

[jira] [Commented] (KAFKA-8093) Fix JavaDoc markup

[ https://issues.apache.org/jira/browse/KAFKA-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847073#comment-16847073 ] ASF GitHub Bot commented on KAFKA-8093: --- pkleindl commented on pull request #6439: KAFKA-8093:

[jira] [Commented] (KAFKA-8333) Load high watermark checkpoint only once when handling LeaderAndIsr requests

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

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

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847056#comment-16847056 ] Srikala commented on KAFKA-7500: [~ryannedolan], I configured connect mirrormaker  for replicating

[jira] [Commented] (KAFKA-8333) Load high watermark checkpoint only once when handling LeaderAndIsr requests

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

[jira] [Commented] (KAFKA-8419) Enable KafkaLog4JAppender to use SASL Authentication Callback Handlers

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

[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=16847033#comment-16847033 ] Sophie Blee-Goldman commented on KAFKA-8367: How many state stores are present in your

[jira] [Created] (KAFKA-8421) Allow consumer.poll() to return data in the middle of rebalance

Guozhang Wang created KAFKA-8421: Summary: Allow consumer.poll() to return data in the middle of rebalance Key: KAFKA-8421 URL: https://issues.apache.org/jira/browse/KAFKA-8421 Project: Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-8371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8371. Resolution: Fixed > Remove ReplicaManager dependence from Partition >

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

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

[jira] [Created] (KAFKA-8420) Graceful handling when consumer switches from subscribe to manual assign

Guozhang Wang created KAFKA-8420: Summary: Graceful handling when consumer switches from subscribe to manual assign Key: KAFKA-8420 URL: https://issues.apache.org/jira/browse/KAFKA-8420 Project:

[jira] [Created] (KAFKA-8419) Enable KafkaLog4JAppender to use SASL Authentication Callback Handlers

Ryan P created KAFKA-8419: - Summary: Enable KafkaLog4JAppender to use SASL Authentication Callback Handlers Key: KAFKA-8419 URL: https://issues.apache.org/jira/browse/KAFKA-8419 Project: Kafka

[jira] [Resolved] (KAFKA-8407) Connector client overrides broken on client configs with type 'Class' or 'List'

[ https://issues.apache.org/jira/browse/KAFKA-8407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8407. -- Resolution: Fixed Reviewer: Randall Hauch Fix Version/s: 2.3.0 Merged onto the

[jira] [Commented] (KAFKA-8407) Connector client overrides broken on client configs with type 'Class' or 'List'

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

[jira] [Resolved] (KAFKA-8415) Interface ConnectorClientConfigOverridePolicy needs to be excluded from class loading isolation

[ https://issues.apache.org/jira/browse/KAFKA-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8415. -- Resolution: Fixed Reviewer: Randall Hauch Merged onto the `trunk` and `2.3` branches. >

[jira] [Updated] (KAFKA-8418) Connect System tests are not waiting for REST resources to be registered

[ https://issues.apache.org/jira/browse/KAFKA-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Diachenko updated KAFKA-8418: --- Description: I am getting an error while running Kafka tests: {code} Traceback

[jira] [Updated] (KAFKA-8418) Connect System tests are not waiting for REST resources to be registered

[ https://issues.apache.org/jira/browse/KAFKA-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Diachenko updated KAFKA-8418: --- Description: I am getting an error while running Kafka tests: {code} Traceback

[jira] [Commented] (KAFKA-8415) Interface ConnectorClientConfigOverridePolicy needs to be excluded from class loading isolation

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

[jira] [Updated] (KAFKA-8418) Connect System tests are not waiting for REST resources to be registered

[ https://issues.apache.org/jira/browse/KAFKA-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Diachenko updated KAFKA-8418: --- Fix Version/s: 2.3.0 > Connect System tests are not waiting for REST resources to be

[jira] [Updated] (KAFKA-8418) Connect System tests are not waiting for REST resources to be registered

[ https://issues.apache.org/jira/browse/KAFKA-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Diachenko updated KAFKA-8418: --- Affects Version/s: 2.2.0 > Connect System tests are not waiting for REST resources

[jira] [Updated] (KAFKA-8418) Connect System tests are not waiting for REST resources to be registered

[ https://issues.apache.org/jira/browse/KAFKA-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Diachenko updated KAFKA-8418: --- Component/s: KafkaConnect > Connect System tests are not waiting for REST resources

[jira] [Created] (KAFKA-8418) Connect System tests are not waiting for REST resources to be registered

Oleksandr Diachenko created KAFKA-8418: -- Summary: Connect System tests are not waiting for REST resources to be registered Key: KAFKA-8418 URL: https://issues.apache.org/jira/browse/KAFKA-8418

[jira] [Resolved] (KAFKA-8309) KIP-465: Add Consolidated Connector Endpoint to Connect REST API

[ https://issues.apache.org/jira/browse/KAFKA-8309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8309. -- Resolution: Fixed Assignee: dan norwood Reviewer: Randall Hauch Fix

[jira] [Commented] (KAFKA-8417) Remove redundant network definition --net=host when starting testing docker containers

[ https://issues.apache.org/jira/browse/KAFKA-8417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846953#comment-16846953 ] ASF GitHub Bot commented on KAFKA-8417: --- cmccabe commented on pull request #6797: KAFKA-8417:

[jira] [Commented] (KAFKA-8417) Remove redundant network definition --net=host when starting testing docker containers

[ https://issues.apache.org/jira/browse/KAFKA-8417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846948#comment-16846948 ] ASF GitHub Bot commented on KAFKA-8417: --- kkonstantine commented on pull request #6797: KAFKA-8417:

[jira] [Created] (KAFKA-8417) Remove redundant network definition --net=host when starting testing docker containers

Konstantine Karantasis created KAFKA-8417: - Summary: Remove redundant network definition --net=host when starting testing docker containers Key: KAFKA-8417 URL:

[jira] [Resolved] (KAFKA-8413) Add possibility to do repartitioning on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8413. Resolution: Not A Problem > Add possibility to do repartitioning on KStream >

[jira] [Commented] (KAFKA-8413) Add possibility to do repartitioning on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846927#comment-16846927 ] Bill Bejeck commented on KAFKA-8413: Hi [~lkokhreidze], No problem at all!  It's a subtle point and

[jira] [Updated] (KAFKA-8416) Improve Documentation for Enabling Optimizations

[ https://issues.apache.org/jira/browse/KAFKA-8416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8416: --- Labels: newbie, (was: ) > Improve Documentation for Enabling Optimizations >

[jira] [Created] (KAFKA-8416) Improve Documentation for Enabling Optimizations

Bill Bejeck created KAFKA-8416: -- Summary: Improve Documentation for Enabling Optimizations Key: KAFKA-8416 URL: https://issues.apache.org/jira/browse/KAFKA-8416 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-8416) Improve Documentation for Enabling Optimizations

[ https://issues.apache.org/jira/browse/KAFKA-8416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8416: --- Component/s: streams > Improve Documentation for Enabling Optimizations >

[jira] [Commented] (KAFKA-8413) Add possibility to do repartitioning on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846916#comment-16846916 ] Levani Kokhreidze commented on KAFKA-8413: -- Hi [~bbejeck], I wasn't passing properties to

[jira] [Commented] (KAFKA-8413) Add possibility to do repartitioning on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846905#comment-16846905 ] Bill Bejeck commented on KAFKA-8413: Hi, [~lkokhreidze] thanks for reporting this.   When you build

[jira] [Commented] (KAFKA-8341) AdminClient should retry coordinator lookup after NOT_COORDINATOR error

[ https://issues.apache.org/jira/browse/KAFKA-8341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846904#comment-16846904 ] ASF GitHub Bot commented on KAFKA-8341: --- soondenana commented on pull request #6723: KAFKA-8341.

[jira] [Commented] (KAFKA-8341) AdminClient should retry coordinator lookup after NOT_COORDINATOR error

[ https://issues.apache.org/jira/browse/KAFKA-8341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846900#comment-16846900 ] ASF GitHub Bot commented on KAFKA-8341: --- soondenana commented on pull request #6723: KAFKA-8341.

[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=16846857#comment-16846857 ] Matthias J. Sax commented on KAFKA-7994: I think it might actually be worth to split the two

[jira] [Commented] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846851#comment-16846851 ] Matthias J. Sax commented on KAFKA-8412: Do you run with EOS enabled? Also, closing() and

[jira] [Commented] (KAFKA-8413) Add possibility to do repartitioning on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846847#comment-16846847 ] Levani Kokhreidze commented on KAFKA-8413: -- Thanks. I'll look into it > Add possibility to do

[jira] [Commented] (KAFKA-8413) Add possibility to do repartitioning on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846844#comment-16846844 ] Matthias J. Sax commented on KAFKA-8413: {quote}I've enabled topology optimization, but in this

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846843#comment-16846843 ] Ted Yu commented on KAFKA-5998: --- Can you move state directory outside of /tmp which is subject to cleaning

[jira] [Comment Edited] (KAFKA-8413) Add possibility to do repartitioning on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846838#comment-16846838 ] Levani Kokhreidze edited comment on KAFKA-8413 at 5/23/19 4:28 PM: --- Hi

[jira] [Commented] (KAFKA-8413) Add possibility to do repartitioning on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846838#comment-16846838 ] Levani Kokhreidze commented on KAFKA-8413: -- Hi Matthias, I've enabled topology optimization,

[jira] [Assigned] (KAFKA-7760) Add broker configuration to set minimum value for segment.bytes and segment.ms

[ https://issues.apache.org/jira/browse/KAFKA-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brandt Newton reassigned KAFKA-7760: Assignee: (was: Brandt Newton) > Add broker configuration to set minimum value for

[jira] [Updated] (KAFKA-8415) Interface ConnectorClientConfigOverridePolicy needs to be excluded from class loading isolation

[ https://issues.apache.org/jira/browse/KAFKA-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-8415: -- Description: Classes or interfaces that implement

[jira] [Commented] (KAFKA-8415) Interface ConnectorClientConfigOverridePolicy needs to be excluded from class loading isolation

[ https://issues.apache.org/jira/browse/KAFKA-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846816#comment-16846816 ] ASF GitHub Bot commented on KAFKA-8415: --- kkonstantine commented on pull request #6796: KAFKA-8415:

[jira] [Commented] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846808#comment-16846808 ] Sebastiaan commented on KAFKA-8412: --- [~mjsax] I can try to reproduce it in development some more but so

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846800#comment-16846800 ] Matthias J. Sax commented on KAFKA-7245: Yes. The classes you listed _implement_ the interface,

[jira] [Updated] (KAFKA-7201) Optimize repartition operations

[ https://issues.apache.org/jira/browse/KAFKA-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-7201: --- Affects Version/s: 2.1.0 > Optimize repartition operations > --- > >

[jira] [Updated] (KAFKA-8414) org.apache.kafka.common.metrics.MetricsTest.testConcurrentReadUpdateReport hang

[ https://issues.apache.org/jira/browse/KAFKA-8414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dan norwood updated KAFKA-8414: --- Description: caveat: this only happens on AMD Epyc machines with >=48 cpus. i have below a bunch of

[jira] [Resolved] (KAFKA-7201) Optimize repartition operations

[ https://issues.apache.org/jira/browse/KAFKA-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7201. Resolution: Fixed Resolved via https://issues.apache.org/jira/browse/KAFKA-6761  > Optimize

[jira] [Updated] (KAFKA-7201) Optimize repartition operations

[ https://issues.apache.org/jira/browse/KAFKA-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-7201: --- Fix Version/s: 2.1.0 > Optimize repartition operations > --- > >

[jira] [Commented] (KAFKA-7201) Optimize repartition operations

[ https://issues.apache.org/jira/browse/KAFKA-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846795#comment-16846795 ] Bill Bejeck commented on KAFKA-7201: [~mjsax] Apologies for the delayed response.  Yes this is

[jira] [Comment Edited] (KAFKA-7201) Optimize repartition operations

[ https://issues.apache.org/jira/browse/KAFKA-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846795#comment-16846795 ] Bill Bejeck edited comment on KAFKA-7201 at 5/23/19 3:37 PM: - [~mjsax]

[jira] [Commented] (KAFKA-8413) Add possibility to do repartitioning on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846791#comment-16846791 ] Matthias J. Sax commented on KAFKA-8413: This should already be fixed. You need to turn on

[jira] [Commented] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846787#comment-16846787 ] Matthias J. Sax commented on KAFKA-8412: Thanks for reporting this. What I don't understand is,

[jira] [Created] (KAFKA-8415) Interface ConnectorClientConfigOverridePolicy needs to be excluded from class loading isolation

Konstantine Karantasis created KAFKA-8415: - Summary: Interface ConnectorClientConfigOverridePolicy needs to be excluded from class loading isolation Key: KAFKA-8415 URL:

[jira] [Updated] (KAFKA-8414) org.apache.kafka.common.metrics.MetricsTest.testConcurrentReadUpdateReport hang

[ https://issues.apache.org/jira/browse/KAFKA-8414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dan norwood updated KAFKA-8414: --- Description: caveat: this only happens on AMD Epyc machines with >=48 cpus. i have below a bunch of

[jira] [Created] (KAFKA-8414) org.apache.kafka.common.metrics.MetricsTest.testConcurrentReadUpdateReport hang

dan norwood created KAFKA-8414: -- Summary: org.apache.kafka.common.metrics.MetricsTest.testConcurrentReadUpdateReport hang Key: KAFKA-8414 URL: https://issues.apache.org/jira/browse/KAFKA-8414 Project:

[jira] [Updated] (KAFKA-8411) Option to keep tombstones forever in compacted logs

[ https://issues.apache.org/jira/browse/KAFKA-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8411: --- Priority: Minor (was: Major) > Option to keep tombstones forever in compacted logs >

[jira] [Commented] (KAFKA-8411) Option to keep tombstones forever in compacted logs

[ https://issues.apache.org/jira/browse/KAFKA-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846775#comment-16846775 ] Matthias J. Sax commented on KAFKA-8411: Well. The config is of type long. If you set it to

[jira] [Updated] (KAFKA-8413) Add possibility to do repartitioning on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-8413: - Description: Consider following code: {code:java} final KStream streamByProfileId =

[jira] [Commented] (KAFKA-8413) Add possibility to do repartitioning on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846740#comment-16846740 ] Levani Kokhreidze commented on KAFKA-8413: -- Happy to work on KIP if this feature makes sense. >

[jira] [Created] (KAFKA-8413) Add possibility to do repartitioning on KStream

Levani Kokhreidze created KAFKA-8413: Summary: Add possibility to do repartitioning on KStream Key: KAFKA-8413 URL: https://issues.apache.org/jira/browse/KAFKA-8413 Project: Kafka Issue

[jira] [Comment Edited] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846566#comment-16846566 ] Andrew edited comment on KAFKA-5998 at 5/23/19 11:32 AM: - I have just seen this

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846598#comment-16846598 ] Omkar Mestry commented on KAFKA-7245: - [~mjsax]  The core stream also has some class which are using

[jira] [Comment Edited] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846566#comment-16846566 ] Andrew edited comment on KAFKA-5998 at 5/23/19 9:29 AM: I have just seen this

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846566#comment-16846566 ] Andrew commented on KAFKA-5998: --- I have just seen this error with kafka 2.2.0 and confluent 5.2.1. We are

[jira] [Created] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

Sebastiaan created KAFKA-8412: - Summary: Still a nullpointer exception thrown on shutdown while flushing before closing producers Key: KAFKA-8412 URL: https://issues.apache.org/jira/browse/KAFKA-8412

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846512#comment-16846512 ] Vivek Yadav commented on KAFKA-4084: [~jiaxinye] Is it works for you? > automated leader rebalance

[jira] [Created] (KAFKA-8411) Option to keep tombstones forever in compacted logs

Lukas Welte created KAFKA-8411: -- Summary: Option to keep tombstones forever in compacted logs Key: KAFKA-8411 URL: https://issues.apache.org/jira/browse/KAFKA-8411 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-8229) Connect Sink Task updates nextCommit when commitRequest is true

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