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: Im
[
https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846512#comment-16846512
]
Vivek Yadav commented on KAFKA-4084:
[~jiaxinye] Is it works for you?
> automated le
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
Proj
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846566#comment-16846566
]
Andrew commented on KAFKA-5998:
---
I have just seen this error with kafka 2.2.0 and confluent
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846566#comment-16846566
]
Andrew edited comment on KAFKA-5998 at 5/23/19 9:29 AM:
I have ju
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846598#comment-16846598
]
Omkar Mestry commented on KAFKA-7245:
-
[~mjsax] The core stream also has some class
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846566#comment-16846566
]
Andrew edited comment on KAFKA-5998 at 5/23/19 11:32 AM:
-
I have
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 T
[
https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846740#comment-16846740
]
Levani Kokhreidze commented on KAFKA-8413:
--
Happy to work on KIP if this feature
[
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 = strea
[
https://issues.apache.org/jira/browse/KAFKA-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846775#comment-16846775
]
Matthias J. Sax commented on KAFKA-8411:
Well. The config is of type long. If you
[
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
> --
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: K
[
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
Konstantine Karantasis created KAFKA-8415:
-
Summary: Interface ConnectorClientConfigOverridePolicy needs to be
excluded from class loading isolation
Key: KAFKA-8415
URL: https://issues.apache.org/jira/brow
[
https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846787#comment-16846787
]
Matthias J. Sax commented on KAFKA-8412:
Thanks for reporting this. What I don't
[
https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846791#comment-16846791
]
Matthias J. Sax commented on KAFKA-8413:
This should already be fixed. You need t
[
https://issues.apache.org/jira/browse/KAFKA-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846795#comment-16846795
]
Bill Bejeck edited comment on KAFKA-7201 at 5/23/19 3:37 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846795#comment-16846795
]
Bill Bejeck commented on KAFKA-7201:
[~mjsax]
Apologies for the delayed response. Y
[
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 repart
[
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
> ---
>
>
[
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
> ---
>
>
[
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
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846800#comment-16846800
]
Matthias J. Sax commented on KAFKA-7245:
Yes. The classes you listed _implement_
[
https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846808#comment-16846808
]
Sebastiaan commented on KAFKA-8412:
---
[~mjsax] I can try to reproduce it in development
[
https://issues.apache.org/jira/browse/KAFKA-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846816#comment-16846816
]
ASF GitHub Bot commented on KAFKA-8415:
---
kkonstantine commented on pull request #67
[
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 {{ConnectorClientConfigOverri
[
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 seg
[
https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846838#comment-16846838
]
Levani Kokhreidze commented on KAFKA-8413:
--
Hi Matthias,
I've enabled topology
[
https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846838#comment-16846838
]
Levani Kokhreidze edited comment on KAFKA-8413 at 5/23/19 4:28 PM:
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846843#comment-16846843
]
Ted Yu commented on KAFKA-5998:
---
Can you move state directory outside of /tmp which is subj
[
https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846844#comment-16846844
]
Matthias J. Sax commented on KAFKA-8413:
{quote}I've enabled topology optimizatio
[
https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846847#comment-16846847
]
Levani Kokhreidze commented on KAFKA-8413:
--
Thanks. I'll look into it
> Add pos
[
https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846851#comment-16846851
]
Matthias J. Sax commented on KAFKA-8412:
Do you run with EOS enabled?
Also, clos
[
https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846857#comment-16846857
]
Matthias J. Sax commented on KAFKA-7994:
I think it might actually be worth to sp
[
https://issues.apache.org/jira/browse/KAFKA-8341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846900#comment-16846900
]
ASF GitHub Bot commented on KAFKA-8341:
---
soondenana commented on pull request #6723
[
https://issues.apache.org/jira/browse/KAFKA-8341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846904#comment-16846904
]
ASF GitHub Bot commented on KAFKA-8341:
---
soondenana commented on pull request #6723
[
https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846905#comment-16846905
]
Bill Bejeck commented on KAFKA-8413:
Hi, [~lkokhreidze] thanks for reporting this.
[
https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846916#comment-16846916
]
Levani Kokhreidze commented on KAFKA-8413:
--
Hi [~bbejeck],
I wasn't passing pro
[
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
> ---
[
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
> ---
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: Improv
[
https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846927#comment-16846927
]
Bill Bejeck commented on KAFKA-8413:
Hi [~lkokhreidze],
No problem at all! It's a s
[
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
> -
Konstantine Karantasis created KAFKA-8417:
-
Summary: Remove redundant network definition --net=host when
starting testing docker containers
Key: KAFKA-8417
URL: https://issues.apache.org/jira/browse/KAFKA-
[
https://issues.apache.org/jira/browse/KAFKA-8417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846948#comment-16846948
]
ASF GitHub Bot commented on KAFKA-8417:
---
kkonstantine commented on pull request #67
[
https://issues.apache.org/jira/browse/KAFKA-8417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846953#comment-16846953
]
ASF GitHub Bot commented on KAFKA-8417:
---
cmccabe commented on pull request #6797: K
[
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 Ver
[
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 t
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
Pr
[
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 to
[
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
[
https://issues.apache.org/jira/browse/KAFKA-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846985#comment-16846985
]
ASF GitHub Bot commented on KAFKA-8415:
---
rhauch commented on pull request #6796: KA
[
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 (mos
[
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 (most
[
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.
>
[
https://issues.apache.org/jira/browse/KAFKA-8407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846991#comment-16846991
]
ASF GitHub Bot commented on KAFKA-8407:
---
rhauch commented on pull request #6789: KA
[
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
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
Issue
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: Kafka
[
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
> -
[
https://issues.apache.org/jira/browse/KAFKA-8371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847026#comment-16847026
]
ASF GitHub Bot commented on KAFKA-8371:
---
hachikuji commented on pull request #6705:
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
[
https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847033#comment-16847033
]
Sophie Blee-Goldman commented on KAFKA-8367:
How many state stores are presen
[
https://issues.apache.org/jira/browse/KAFKA-8419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847043#comment-16847043
]
ASF GitHub Bot commented on KAFKA-8419:
---
rnpridgeon commented on pull request #6799
[
https://issues.apache.org/jira/browse/KAFKA-8333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847047#comment-16847047
]
ASF GitHub Bot commented on KAFKA-8333:
---
hachikuji commented on pull request #6696:
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847056#comment-16847056
]
Srikala commented on KAFKA-7500:
[~ryannedolan],
I configured connect mirrormaker for r
[
https://issues.apache.org/jira/browse/KAFKA-8333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847071#comment-16847071
]
ASF GitHub Bot commented on KAFKA-8333:
---
hachikuji commented on pull request #6800:
[
https://issues.apache.org/jira/browse/KAFKA-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847073#comment-16847073
]
ASF GitHub Bot commented on KAFKA-8093:
---
pkleindl commented on pull request #6439:
[
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
>
[
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
>
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
[
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 req
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: Impr
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
[
https://issues.apache.org/jira/browse/KAFKA-8311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847170#comment-16847170
]
Boyang Chen commented on KAFKA-8311:
[~clearpal7] No worry, let me take a look of you
[
https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847174#comment-16847174
]
Boyang Chen commented on KAFKA-8342:
[~clearpal7] Let me know if this sounds interest
[
https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847211#comment-16847211
]
Sebastiaan commented on KAFKA-8412:
---
[~mjsax] yes we are using EOS.
And yeah you're ri
[
https://issues.apache.org/jira/browse/KAFKA-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847241#comment-16847241
]
ASF GitHub Bot commented on KAFKA-8424:
---
abbccdda commented on pull request #6805:
[
https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847245#comment-16847245
]
WooYoung commented on KAFKA-8342:
-
[~bchen225242] I`m interested in this ticket to help t
[
https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847286#comment-16847286
]
Boyang Chen commented on KAFKA-8342:
[~clearpal7] Yea, feel free to take it. I will p
81 matches
Mail list logo
