[jira] [Commented] (KAFKA-12549) Allow state stores to opt-in transactional support

2024-01-31 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812756#comment-17812756 ] highluck commented on KAFKA-12549: -- [~guozhang] Can I take the work with you? > Allow

[jira] [Assigned] (KAFKA-15744) KRaft support in CustomQuotaCallbackTest

2024-01-31 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-15744: Assignee: highluck > KRaft support in CustomQuotaCallbackTest > -

[jira] [Assigned] (KAFKA-15716) KRaft support in EpochDrivenReplicationProtocolAcceptanceTest

2024-01-27 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-15716: Assignee: highluck > KRaft support in EpochDrivenReplicationProtocolAcceptanceTest >

[jira] [Assigned] (KAFKA-15715) KRaft support in UpdateFeaturesTest

2024-01-27 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-15715: Assignee: (was: highluck) > KRaft support in UpdateFeaturesTest > ---

[jira] [Assigned] (KAFKA-15715) KRaft support in UpdateFeaturesTest

2024-01-27 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-15715: Assignee: highluck > KRaft support in UpdateFeaturesTest > --- >

[jira] [Commented] (KAFKA-16066) Upgrade apacheds to 2.0.0.AM27

2024-01-26 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811467#comment-17811467 ] highluck commented on KAFKA-16066: -- thanks [~divijvaidya] :) > Upgrade apacheds to 2.0

[jira] [Assigned] (KAFKA-16066) Upgrade apacheds to 2.0.0.AM27

2024-01-26 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-16066: Assignee: highluck > Upgrade apacheds to 2.0.0.AM27 > -- > >

[jira] [Commented] (KAFKA-16066) Upgrade apacheds to 2.0.0.AM27

2024-01-22 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17809731#comment-17809731 ] highluck commented on KAFKA-16066: -- If there is no one else to do it, can I do it? > U

[jira] [Commented] (KAFKA-16084) Simplify and deduplicate StandaloneHerderTest mocking

2024-01-22 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17809693#comment-17809693 ] highluck commented on KAFKA-16084: -- [~gharris1727] Can I do it?  > Simplify and dedupl

[jira] [Resolved] (KAFKA-10283) Consolidate client-level and consumer-level assignment within ClientState

2022-01-17 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck resolved KAFKA-10283. -- Resolution: Fixed > Consolidate client-level and consumer-level assignment within ClientState > --

[jira] [Commented] (KAFKA-10575) StateRestoreListener#onRestoreEnd should always be triggered

2021-03-24 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308411#comment-17308411 ] highluck commented on KAFKA-10575: -- [~ableegoldman] Yes, I am willing to work. However

[jira] [Assigned] (KAFKA-7785) Remove PartitionGrouper interface and it's config and move DefaultPartitionGrouper to internal package

2021-03-08 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-7785: --- Assignee: highluck > Remove PartitionGrouper interface and it's config and move > DefaultPartitionG

[jira] [Commented] (KAFKA-7785) Remove PartitionGrouper interface and it's config and move DefaultPartitionGrouper to internal package

2021-03-08 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297768#comment-17297768 ] highluck commented on KAFKA-7785: - Oh thank [~mjsax]   > Remove PartitionGrouper interf

[jira] [Commented] (KAFKA-4928) Add integration test for DumpLogSegments

2021-01-11 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17262609#comment-17262609 ] highluck commented on KAFKA-4928: - [~ijuma]  Is it okay for me to do this? thanks > Add

[jira] [Commented] (KAFKA-10283) Consolidate client-level and consumer-level assignment within ClientState

2021-01-11 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17262605#comment-17262605 ] highluck commented on KAFKA-10283: -- [~ableegoldman] Please review once! Thanks! > Co

[jira] [Assigned] (KAFKA-10769) Remove JoinGroupRequest#containsValidPattern as it is duplicate to Topic#containsValidPattern

2021-01-03 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-10769: Assignee: highluck (was: Arun Parthiban) > Remove JoinGroupRequest#containsValidPattern as it is

[jira] [Commented] (KAFKA-10769) Remove JoinGroupRequest#containsValidPattern as it is duplicate to Topic#containsValidPattern

2021-01-03 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17257896#comment-17257896 ] highluck commented on KAFKA-10769: -- [~chia7712] thanks :) > Remove JoinGroupRequest#co

[jira] [Assigned] (KAFKA-10575) StateRestoreListener#onRestoreEnd should always be triggered

2020-12-07 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-10575: Assignee: highluck > StateRestoreListener#onRestoreEnd should always be triggered > -

[jira] [Commented] (KAFKA-10575) StateRestoreListener#onRestoreEnd should always be triggered

2020-12-07 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245318#comment-17245318 ] highluck commented on KAFKA-10575: -- [~Yohan123] Are you working on this task? > State

[jira] [Commented] (KAFKA-10769) Remove JoinGroupRequest#containsValidPattern as it is duplicate to Topic#containsValidPattern

2020-12-07 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245313#comment-17245313 ] highluck commented on KAFKA-10769: -- [~parth017] Are you working on this task? > Remov

[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

2020-12-07 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245308#comment-17245308 ] highluck commented on KAFKA-9259: - [~omanges] Are you working on this task? > suppress(

[jira] [Commented] (KAFKA-1043) Time-consuming FetchRequest could block other request in the response queue

2020-12-07 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-1043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245298#comment-17245298 ] highluck commented on KAFKA-1043: - [~guozhang] Is this still a problem? > Time-consumin

[jira] [Commented] (KAFKA-10283) Consolidate client-level and consumer-level assignment within ClientState

2020-12-06 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245005#comment-17245005 ] highluck commented on KAFKA-10283: -- [~guozhang] Please review once! > Consolidate cli

[jira] [Assigned] (KAFKA-10283) Consolidate client-level and consumer-level assignment within ClientState

2020-09-17 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-10283: Assignee: highluck > Consolidate client-level and consumer-level assignment within ClientState >

[jira] [Commented] (KAFKA-10362) When resuming Streams active task with EOS, the checkpoint file should be deleted

2020-08-24 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17183075#comment-17183075 ] highluck commented on KAFKA-10362: -- [~ipasynkov] Are you working on it? If not, can I

[jira] [Commented] (KAFKA-10283) Consolidate client-level and consumer-level assignment within ClientState

2020-07-30 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168029#comment-17168029 ] highluck commented on KAFKA-10283: -- [~guozhang] Can I pick this issue? Is there any s

[jira] [Commented] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

2020-07-16 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159285#comment-17159285 ] highluck commented on KAFKA-5488: - @Ivan Ponomarev thanks for comment! Call me whenever y

[jira] [Commented] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

2020-07-15 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17158897#comment-17158897 ] highluck commented on KAFKA-5488: -  [~iponomarev] Are you willing to continue working? t

[jira] [Commented] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

2020-07-15 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17158842#comment-17158842 ] highluck commented on KAFKA-5488: - ok thank you! :) > KStream.branch should not return a

[jira] [Assigned] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

2020-07-15 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-5488: --- Assignee: highluck > KStream.branch should not return a Array of streams we have to access by > kno

[jira] [Commented] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

2020-07-15 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17158839#comment-17158839 ] highluck commented on KAFKA-5488: - [~mjsax] thankyou! I didn't have any people assigned

[jira] [Assigned] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

2020-07-15 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-5488: --- Assignee: (was: highluck) > KStream.branch should not return a Array of streams we have to acces

[jira] [Comment Edited] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

2020-07-15 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17158505#comment-17158505 ] highluck edited comment on KAFKA-5488 at 7/15/20, 4:20 PM: --- I t

[jira] [Comment Edited] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

2020-07-15 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17158505#comment-17158505 ] highluck edited comment on KAFKA-5488 at 7/15/20, 4:20 PM: --- I t

[jira] [Commented] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

2020-07-15 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17158505#comment-17158505 ] highluck commented on KAFKA-5488: - I think there are some unnecessary interfaces ``` {{Br

[jira] [Assigned] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

2020-07-15 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-5488: --- Assignee: highluck > KStream.branch should not return a Array of streams we have to access by > kno

[jira] [Assigned] (KAFKA-8666) Improve Documentation on usage of Materialized config object

2020-07-06 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-8666: --- Assignee: (was: highluck) > Improve Documentation on usage of Materialized config object > -

[jira] [Assigned] (KAFKA-8666) Improve Documentation on usage of Materialized config object

2020-07-06 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-8666: --- Assignee: highluck > Improve Documentation on usage of Materialized config object >

[jira] [Assigned] (KAFKA-7711) Add a bounded flush() API to Kafka Producer

2020-02-24 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-7711: --- Assignee: (was: highluck) > Add a bounded flush() API to Kafka Producer > -

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-02-24 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044126#comment-17044126 ] highluck commented on KAFKA-9455: - [~guozhang] thank you! `JoinWindowStore` is my mista

[jira] [Issue Comment Deleted] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-02-20 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck updated KAFKA-9455: Comment: was deleted (was: @Guozhang Thanks! it was helpful!) > Consider using TreeMap for in-memory stor

[jira] [Assigned] (KAFKA-7711) Add a bounded flush() API to Kafka Producer

2020-02-19 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-7711: --- Assignee: highluck > Add a bounded flush() API to Kafka Producer >

[jira] [Commented] (KAFKA-9559) Change the default "default serde" from ByteArraySerde to null

2020-02-16 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038032#comment-17038032 ] highluck commented on KAFKA-9559: - [~mjsax] oh thank you, for your care! i'm understand

[jira] [Assigned] (KAFKA-9559) Change the default "default serde" from ByteArraySerde to null

2020-02-16 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-9559: --- Assignee: (was: highluck) > Change the default "default serde" from ByteArraySerde to null > ---

[jira] [Assigned] (KAFKA-9559) Change the default "default serde" from ByteArraySerde to null

2020-02-14 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-9559: --- Assignee: highluck > Change the default "default serde" from ByteArraySerde to null > --

[jira] [Commented] (KAFKA-7499) Extend ProductionExceptionHandler to cover serialization exceptions

2020-02-13 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036321#comment-17036321 ] highluck commented on KAFKA-7499: - [~jbfletch], [~mjsax] Is this ticket in progress? If

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-02-13 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036300#comment-17036300 ] highluck commented on KAFKA-9455: - [~guozhang] I don't know if I understand.. I'm tryin

[jira] [Issue Comment Deleted] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-02-12 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck updated KAFKA-9455: Comment: was deleted (was: [~guozhang] I have one more question What do you think about splitting a Windo

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-02-11 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035117#comment-17035117 ] highluck commented on KAFKA-9455: - [~guozhang] I have one more question What do you thi

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-02-11 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034927#comment-17034927 ] highluck commented on KAFKA-9455: - @Guozhang Thanks! it was helpful! > Consider using T

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-02-11 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034913#comment-17034913 ] highluck commented on KAFKA-9455: - @Guozhang Wang Thanks! you Want to add a new point ap

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-02-11 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034478#comment-17034478 ] highluck commented on KAFKA-9455: - [~guozhang] I have a question. Are you referring to

[jira] [Updated] (KAFKA-9483) Add Scala KStream#toTable to the Streams DSL

2020-02-11 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck updated KAFKA-9483: Description: [KIP-523: Add KStream#toTable to the Streams DSL|https://cwiki.apache.org/confluence/display/

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-02-04 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029848#comment-17029848 ] highluck commented on KAFKA-9455: - [~ableegoldman]  Thanks for the explanation! [~guozh

[jira] [Assigned] (KAFKA-9290) Update IQ related JavaDocs

2020-01-31 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-9290: --- Assignee: highluck > Update IQ related JavaDocs > -- > > Key

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-01-31 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17027988#comment-17027988 ] highluck commented on KAFKA-9455: - [~guozhang] Do I need a KIP? > Consider using TreeMa

[jira] [Resolved] (KAFKA-9403) Migrate BaseConsumer to Consumer

2020-01-30 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck resolved KAFKA-9403. - Resolution: Not A Bug > Migrate BaseConsumer to Consumer > > >

[jira] [Comment Edited] (KAFKA-8382) Add TimestampedSessionStore

2020-01-30 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17027072#comment-17027072 ] highluck edited comment on KAFKA-8382 at 1/30/20 11:22 PM: --- [~m

[jira] [Commented] (KAFKA-8382) Add TimestampedSessionStore

2020-01-30 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17027072#comment-17027072 ] highluck commented on KAFKA-8382: - [https://github.com/apache/kafka/pull/8022] > Add Tim

[jira] [Issue Comment Deleted] (KAFKA-8382) Add TimestampedSessionStore

2020-01-30 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck updated KAFKA-8382: Comment: was deleted (was: [https://github.com/apache/kafka/pull/8022]) > Add TimestampedSessionStore > --

[jira] [Commented] (KAFKA-8382) Add TimestampedSessionStore

2020-01-30 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17027069#comment-17027069 ] highluck commented on KAFKA-8382: - [https://github.com/apache/kafka/pull/8022] > Add Tim

[jira] [Created] (KAFKA-9483) Add Scala KStream#toTable to the Streams DSL

2020-01-30 Thread highluck (Jira)
highluck created KAFKA-9483: --- Summary: Add Scala KStream#toTable to the Streams DSL Key: KAFKA-9483 URL: https://issues.apache.org/jira/browse/KAFKA-9483 Project: Kafka Issue Type: Improvement

[jira] [Assigned] (KAFKA-8147) Add changelog topic configuration to KTable suppress

2020-01-29 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-8147: --- Assignee: highluck > Add changelog topic configuration to KTable suppress >

[jira] [Assigned] (KAFKA-8382) Add TimestampedSessionStore

2020-01-24 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-8382: --- Assignee: highluck > Add TimestampedSessionStore > --- > > K

[jira] [Assigned] (KAFKA-9290) Update IQ related JavaDocs

2020-01-19 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-9290: --- Assignee: (was: highluck) > Update IQ related JavaDocs > -- > >

[jira] [Assigned] (KAFKA-9290) Update IQ related JavaDocs

2020-01-19 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-9290: --- Assignee: highluck > Update IQ related JavaDocs > -- > > Key

[jira] [Assigned] (KAFKA-7658) Add KStream#toTable to the Streams DSL

2020-01-18 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-7658: --- Assignee: highluck (was: Aishwarya Pradeep Kumar) > Add KStream#toTable to the Streams DSL > --

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

2020-01-17 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018432#comment-17018432 ] highluck commented on KAFKA-7658: - I wanted to say Is it okay if I pr?! > Add KStream#t

[jira] [Commented] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

2020-01-16 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017571#comment-17017571 ] highluck commented on KAFKA-9042: - [~mjsax] Thank you for your reply   Sorry. It was

[jira] [Issue Comment Deleted] (KAFKA-9440) Add ConsumerGroupCommand to delete static members

2020-01-16 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck updated KAFKA-9440: Comment: was deleted (was: [~bchen225242] Can I take this ticket with me?) > Add ConsumerGroupCommand to

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

2020-01-16 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017315#comment-17017315 ] highluck commented on KAFKA-7658: - [~mjsax] If I am not ready now, can I take my ticket

[jira] [Commented] (KAFKA-9440) Add ConsumerGroupCommand to delete static members

2020-01-16 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017080#comment-17017080 ] highluck commented on KAFKA-9440: - [~bchen225242] Can I take this ticket with me? > Add

[jira] [Comment Edited] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

2020-01-16 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017077#comment-17017077 ] highluck edited comment on KAFKA-9042 at 1/16/20 4:18 PM: -- [~mjs

[jira] [Commented] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

2020-01-16 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017077#comment-17017077 ] highluck commented on KAFKA-9042: - [~mjsax]  [~bchen225242] I create a KIP, I modified

[jira] [Comment Edited] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

2020-01-14 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015511#comment-17015511 ] highluck edited comment on KAFKA-9042 at 1/15/20 4:15 AM: --   [~

[jira] [Commented] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

2020-01-14 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015511#comment-17015511 ] highluck commented on KAFKA-9042: -   [~mjsax] Thank you !! Can you give me write permi

[jira] [Commented] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

2020-01-14 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015214#comment-17015214 ] highluck commented on KAFKA-9042: - [~bchen225242] [~mjsax] May I ask for a review? > Au

[jira] [Issue Comment Deleted] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

2020-01-14 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck updated KAFKA-9042: Comment: was deleted (was: [~bchen225242] I don't know if I understand well, but please review it!) > Aut

[jira] [Updated] (KAFKA-9403) Migrate BaseConsumer to Consumer

2020-01-13 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck updated KAFKA-9403: Summary: Migrate BaseConsumer to Consumer (was: Remove BaseConsumer from Mirrormaker) > Migrate BaseConsu

[jira] [Commented] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

2020-01-13 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014457#comment-17014457 ] highluck commented on KAFKA-9042: - [~bchen225242] I don't know if I understand well, but

[jira] [Issue Comment Deleted] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

2020-01-13 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck updated KAFKA-9042: Comment: was deleted (was: [~bchen225242]   Is it okay if I take this ticket?) > Auto infer external topi

[jira] [Assigned] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

2020-01-13 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-9042: --- Assignee: highluck > Auto infer external topic partitions in stream reset tool > ---

[jira] [Commented] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

2020-01-13 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014404#comment-17014404 ] highluck commented on KAFKA-9042: - [~bchen225242]   Is it okay if I take this ticket? >

[jira] [Commented] (KAFKA-9152) Improve Sensor Retrieval

2020-01-13 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014380#comment-17014380 ] highluck commented on KAFKA-9152: - [~cadonna] [https://github.com/apache/kafka/pull/7928

[jira] [Comment Edited] (KAFKA-9403) Remove BaseConsumer from Mirrormaker

2020-01-13 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014373#comment-17014373 ] highluck edited comment on KAFKA-9403 at 1/13/20 2:36 PM: -- [~iju

[jira] [Commented] (KAFKA-9403) Remove BaseConsumer from Mirrormaker

2020-01-13 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014373#comment-17014373 ] highluck commented on KAFKA-9403: - [~ijuma] [https://github.com/apache/kafka/pull/7935]

[jira] [Commented] (KAFKA-9403) Remove BaseConsumer from Mirrormaker

2020-01-13 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014366#comment-17014366 ] highluck commented on KAFKA-9403: - [~ijuma] Can I ask for a review? > Remove BaseConsum

[jira] [Assigned] (KAFKA-9129) Add Thread ID to the InternalProcessorContext

2020-01-13 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-9129: --- Assignee: (was: highluck) > Add Thread ID to the InternalProcessorContext >

[jira] [Created] (KAFKA-9403) Remove BaseConsumer from Mirrormaker

2020-01-12 Thread highluck (Jira)
highluck created KAFKA-9403: --- Summary: Remove BaseConsumer from Mirrormaker Key: KAFKA-9403 URL: https://issues.apache.org/jira/browse/KAFKA-9403 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-9402) PartitionStates update Improvement Opinion

2020-01-12 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck resolved KAFKA-9402. - Resolution: Not A Problem > PartitionStates update Improvement Opinion >

[jira] [Created] (KAFKA-9402) PartitionStates update Improvement Opinion

2020-01-12 Thread highluck (Jira)
highluck created KAFKA-9402: --- Summary: PartitionStates update Improvement Opinion Key: KAFKA-9402 URL: https://issues.apache.org/jira/browse/KAFKA-9402 Project: Kafka Issue Type: Improvement Af

[jira] [Commented] (KAFKA-9090) LeaveGroup admin request should enforce minimum version

2020-01-11 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013659#comment-17013659 ] highluck commented on KAFKA-9090: - [~bchen225242]  Is this ticket valid? > LeaveGroup a

[jira] [Commented] (KAFKA-3416) Update Fetcher to return Future for Metadata requests

2020-01-11 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013649#comment-17013649 ] highluck commented on KAFKA-3416: - [~john.warner] Is this ticket valid? If so, can I do

[jira] [Assigned] (KAFKA-3416) Update Fetcher to return Future for Metadata requests

2020-01-11 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-3416: --- Assignee: (was: highluck) > Update Fetcher to return Future for Metadata requests >

[jira] [Issue Comment Deleted] (KAFKA-3416) Update Fetcher to return Future for Metadata requests

2020-01-11 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck updated KAFKA-3416: Comment: was deleted (was: [~john.warner] Can you assign me a ticket? try it) > Update Fetcher to return

[jira] [Assigned] (KAFKA-3416) Update Fetcher to return Future for Metadata requests

2020-01-11 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-3416: --- Assignee: highluck > Update Fetcher to return Future for Metadata requests > ---

[jira] [Commented] (KAFKA-2758) Improve Offset Commit Behavior

2020-01-10 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-2758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012672#comment-17012672 ] highluck commented on KAFKA-2758: - [~guozhang] Is this issue still open   > Improve Of

[jira] [Comment Edited] (KAFKA-2758) Improve Offset Commit Behavior

2020-01-10 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-2758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012672#comment-17012672 ] highluck edited comment on KAFKA-2758 at 1/10/20 10:16 AM: --- [~g

[jira] [Commented] (KAFKA-9152) Improve Sensor Retrieval

2020-01-10 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012572#comment-17012572 ] highluck commented on KAFKA-9152: - [~cadonna] [https://github.com/apache/kafka/pull/7914

[jira] [Comment Edited] (KAFKA-9152) Improve Sensor Retrieval

2020-01-10 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012572#comment-17012572 ] highluck edited comment on KAFKA-9152 at 1/10/20 8:40 AM: -- [~cad

  1   2   >