[jira] [Commented] (KAFKA-10875) offsetsForTimes returns null for some partitions when it shouldn't?

2021-01-20 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17268468#comment-17268468 ] huxihx commented on KAFKA-10875: [~gongyifei] What's the version for the broker? Besides

[jira] [Comment Edited] (KAFKA-10606) Auto create non-existent topics when fetching metadata for all topics

2020-10-14 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213813#comment-17213813 ] huxihx edited comment on KAFKA-10606 at 10/14/20, 10:45 AM:

[jira] [Commented] (KAFKA-10606) Auto create non-existent topics when fetching metadata for all topics

2020-10-14 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213813#comment-17213813 ] huxihx commented on KAFKA-10606: I am wondering if we could change the default value for

[jira] [Commented] (KAFKA-10576) Different behavior of commitSync and commitAsync

2020-10-09 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211577#comment-17211577 ] huxihx commented on KAFKA-10576: `commitAsync` does need subsequent `poll` calls to take

[jira] [Resolved] (KAFKA-10584) IndexSearchType should use sealed trait instead of Enumeration

2020-10-09 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-10584. Fix Version/s: 2.7.0 Resolution: Fixed > IndexSearchType should use sealed trait instead of Enumera

[jira] [Assigned] (KAFKA-10584) IndexSearchType should use sealed trait instead of Enumeration

2020-10-08 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-10584: -- Assignee: huxihx > IndexSearchType should use sealed trait instead of Enumeration > -

[jira] [Commented] (KAFKA-10467) kafka-topic --describe fails for topic created by "produce"

2020-09-08 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17192585#comment-17192585 ] huxihx commented on KAFKA-10467: Seems the problem is caused by another issue since it s

[jira] [Resolved] (KAFKA-10456) wrong description in kafka-console-producer.sh help

2020-09-02 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-10456. Fix Version/s: 2.7.0 Resolution: Fixed > wrong description in kafka-console-producer.sh help >

[jira] [Assigned] (KAFKA-10456) wrong description in kafka-console-producer.sh help

2020-09-01 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-10456: -- Assignee: huxihx > wrong description in kafka-console-producer.sh help >

[jira] [Commented] (KAFKA-10450) console-producer throws Uncaught error in kafka producer I/O thread:  (org.apache.kafka.clients.producer.internals.Sender) java.lang.IllegalStateException: There are n

2020-08-31 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188082#comment-17188082 ] huxihx commented on KAFKA-10450: Same version for both clients and brokers? > console-p

[jira] [Commented] (KAFKA-10431) ProducerPerformance with payloadFile arg: add support for sequential or random outputs

2020-08-26 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17185531#comment-17185531 ] huxihx commented on KAFKA-10431: Seems adding a new option to ProducerPerformance requir

[jira] [Resolved] (KAFKA-9344) Logged consumer config does not always match actual config values

2020-08-25 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-9344. --- Resolution: Fixed > Logged consumer config does not always match actual config values > -

[jira] [Resolved] (KAFKA-10407) add linger.ms parameter support to KafkaLog4jAppender

2020-08-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-10407. Fix Version/s: 2.7.0 Resolution: Fixed > add linger.ms parameter support to KafkaLog4jAppender > --

[jira] [Commented] (KAFKA-10407) add linger.ms parameter support to KafkaLog4jAppender

2020-08-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180901#comment-17180901 ] huxihx commented on KAFKA-10407: Merged this to trunk and 2.7 branch. > add linger.ms p

[jira] [Assigned] (KAFKA-10407) add linger.ms parameter support to KafkaLog4jAppender

2020-08-16 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-10407: -- Assignee: huxihx > add linger.ms parameter support to KafkaLog4jAppender > --

[jira] [Resolved] (KAFKA-10305) Print usage when parsing fails for ConsumerPerformance

2020-07-25 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-10305. Fix Version/s: 2.7.0 Resolution: Fixed > Print usage when parsing fails for ConsumerPerformance > -

[jira] [Created] (KAFKA-10305) Print usage when parsing fails for ConsumerPerformance

2020-07-23 Thread huxihx (Jira)
huxihx created KAFKA-10305: -- Summary: Print usage when parsing fails for ConsumerPerformance Key: KAFKA-10305 URL: https://issues.apache.org/jira/browse/KAFKA-10305 Project: Kafka Issue Type: Improv

[jira] [Resolved] (KAFKA-10268) dynamic config like "--delete-config log.retention.ms" doesn't work

2020-07-23 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-10268. Fix Version/s: 2.7.0 Resolution: Fixed > dynamic config like "--delete-config log.retention.ms" doe

[jira] [Commented] (KAFKA-10269) AdminClient ListOffsetsResultInfo/timestamp is always -1

2020-07-21 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162444#comment-17162444 ] huxihx commented on KAFKA-10269: [~d-t-w] Thanks for reporting and feel free to take thi

[jira] [Assigned] (KAFKA-10268) dynamic config like "--delete-config log.retention.ms" is not work

2020-07-14 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-10268: -- Assignee: huxihx > dynamic config like "--delete-config log.retention.ms" is not work > -

[jira] [Comment Edited] (KAFKA-10267) [Documentation] | Correction in kafka-console-producer command

2020-07-11 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155978#comment-17155978 ] huxihx edited comment on KAFKA-10267 at 7/11/20, 12:47 PM: --- --

[jira] [Commented] (KAFKA-10267) [Documentation] | Correction in kafka-console-producer command

2020-07-11 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155978#comment-17155978 ] huxihx commented on KAFKA-10267: `--broker-list` is deprecated. Please stick to using `-

[jira] [Comment Edited] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta

2020-07-06 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151960#comment-17151960 ] huxihx edited comment on KAFKA-10017 at 7/6/20, 11:19 AM: -- [htt

[jira] [Commented] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta

2020-07-06 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151960#comment-17151960 ] huxihx commented on KAFKA-10017: [https://builds.apache.org/job/kafka-pr-jdk14-scala2.13

[jira] [Assigned] (KAFKA-10227) Enforce cleanup policy to only contain compact or delete once

2020-07-03 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-10227: -- Assignee: huxihx > Enforce cleanup policy to only contain compact or delete once > --

[jira] [Updated] (KAFKA-10222) Incorrect methods show up in 0.10 Kafka Streams docs

2020-07-01 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-10222: --- Description: In 0.10 Kafka Streams doc([http://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/st

[jira] [Created] (KAFKA-10222) Incorrect methods show up in 0.10 Kafka Streams docs

2020-07-01 Thread huxihx (Jira)
huxihx created KAFKA-10222: -- Summary: Incorrect methods show up in 0.10 Kafka Streams docs Key: KAFKA-10222 URL: https://issues.apache.org/jira/browse/KAFKA-10222 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-10220) NPE when describing resources

2020-06-30 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148774#comment-17148774 ] huxihx commented on KAFKA-10220: Well, from the broker perspective, you are right. Only

[jira] [Commented] (KAFKA-10220) NPE when describing resources

2020-06-30 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148738#comment-17148738 ] huxihx commented on KAFKA-10220: [~ijuma] This should affect 2.6 as well since `configur

[jira] [Commented] (KAFKA-10220) NPE when describing resources

2020-06-30 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148550#comment-17148550 ] huxihx commented on KAFKA-10220: [~ecomar]  Thanks for reporting. I could not reproduce

[jira] [Commented] (KAFKA-10182) Change number of partitions of __consumer_offsets

2020-06-24 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143807#comment-17143807 ] huxihx commented on KAFKA-10182: [~simpleBread] Did you have any chances to see if creat

[jira] [Commented] (KAFKA-10182) Change number of partitions of __consumer_offsets

2020-06-18 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139155#comment-17139155 ] huxihx commented on KAFKA-10182: You could use `Admin.createPartitions` API to increase

[jira] [Assigned] (KAFKA-9541) Flaky Test DescribeConsumerGroupTest#testDescribeGroupMembersWithShortInitializationTimeout

2020-02-24 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-9541: - Assignee: (was: huxihx) > Flaky Test > DescribeConsumerGroupTest#testDescribeGroupMembersWithShortI

[jira] [Comment Edited] (KAFKA-9541) Flaky Test DescribeConsumerGroupTest#testDescribeGroupMembersWithShortInitializationTimeout

2020-02-12 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035028#comment-17035028 ] huxihx edited comment on KAFKA-9541 at 2/13/20 2:14 AM: Occasiona

[jira] [Updated] (KAFKA-9541) Flaky Test DescribeConsumerGroupTest#testDescribeGroupMembersWithShortInitializationTimeout

2020-02-11 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-9541: -- Summary: Flaky Test DescribeConsumerGroupTest#testDescribeGroupMembersWithShortInitializationTimeout (was: Fl

[jira] [Commented] (KAFKA-9541) Flaky Test DescribeConsumerGroupTest#testDescribeGroupWithShortInitializationTimeout

2020-02-11 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035028#comment-17035028 ] huxihx commented on KAFKA-9541: --- Occasionally the captured exception is DisconnectedExcepti

[jira] [Created] (KAFKA-9541) Flaky Test DescribeConsumerGroupTest#testDescribeGroupWithShortInitializationTimeout

2020-02-11 Thread huxihx (Jira)
huxihx created KAFKA-9541: - Summary: Flaky Test DescribeConsumerGroupTest#testDescribeGroupWithShortInitializationTimeout Key: KAFKA-9541 URL: https://issues.apache.org/jira/browse/KAFKA-9541 Project: Kafka

[jira] [Updated] (KAFKA-9322) Add `tail -n` feature for ConsoleConsumer

2020-01-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-9322: -- Labels: needs-kip (was: ) > Add `tail -n` feature for ConsoleConsumer > --

[jira] [Updated] (KAFKA-8881) Measure thread running time precisely

2020-01-12 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-8881: -- Description: Currently, the code uses `System.currentTimeMillis()` to measure timeout extensively. However, man

[jira] [Updated] (KAFKA-9344) Logged consumer config does not always match actual config values

2019-12-29 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-9344: -- Description: Similar to KAFKA-8928, during consumer construction, some configs might be overridden (client.id f

[jira] [Created] (KAFKA-9344) Logged consumer config does not always match actual config values

2019-12-29 Thread huxihx (Jira)
huxihx created KAFKA-9344: - Summary: Logged consumer config does not always match actual config values Key: KAFKA-9344 URL: https://issues.apache.org/jira/browse/KAFKA-9344 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-9236) Confused log after using CLI scripts to produce messages

2019-12-25 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17003415#comment-17003415 ] huxihx commented on KAFKA-9236: --- [~iamabug] Can we close this Jira now? > Confused log aft

[jira] [Assigned] (KAFKA-9277) move all group state transition rules into their states

2019-12-25 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-9277: - Assignee: dengziming (was: huxihx) > move all group state transition rules into their states >

[jira] [Assigned] (KAFKA-9277) move all group state transition rules into their states

2019-12-25 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-9277: - Assignee: huxihx (was: dengziming) > move all group state transition rules into their states >

[jira] [Assigned] (KAFKA-9254) Topic level configuration failed

2019-12-24 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-9254: - Assignee: huxihx > Topic level configuration failed > > >

[jira] [Updated] (KAFKA-9322) Add `tail -n` feature for ConsoleConsumer

2019-12-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-9322: -- Description: When debugging, it will be convenient to quickly check the last N messages for a partition using C

[jira] [Updated] (KAFKA-9322) Add `tail -n` feature for ConsoleConsumer

2019-12-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-9322: -- Description: When debugging, it will be convenient to quickly check the last N messages for a partition using C

[jira] [Created] (KAFKA-9322) Add `tail -n` feature for ConsoleConsumer

2019-12-19 Thread huxihx (Jira)
huxihx created KAFKA-9322: - Summary: Add `tail -n` feature for ConsoleConsumer Key: KAFKA-9322 URL: https://issues.apache.org/jira/browse/KAFKA-9322 Project: Kafka Issue Type: Improvement C

[jira] [Commented] (KAFKA-9317) Provide a group admin command to get group information or do some admin operation

2019-12-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17000562#comment-17000562 ] huxihx commented on KAFKA-9317: --- Does `kafka-consumer-groups.sh` satisfy your requirement?

[jira] [Commented] (KAFKA-9300) Create a topic based on the specified brokers

2019-12-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16999835#comment-16999835 ] huxihx commented on KAFKA-9300: --- I mean a new config deserves a KIP to have people discuss

[jira] [Created] (KAFKA-9316) ConsoleProducer help info not expose default properties

2019-12-18 Thread huxihx (Jira)
huxihx created KAFKA-9316: - Summary: ConsoleProducer help info not expose default properties Key: KAFKA-9316 URL: https://issues.apache.org/jira/browse/KAFKA-9316 Project: Kafka Issue Type: Improveme

[jira] [Commented] (KAFKA-9300) Create a topic based on the specified brokers

2019-12-16 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997081#comment-16997081 ] huxihx commented on KAFKA-9300: --- This might need a KIP. > Create a topic based on the spec

[jira] [Commented] (KAFKA-9236) Confused log after using CLI scripts to produce messages

2019-12-01 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16985548#comment-16985548 ] huxihx commented on KAFKA-9236: --- Sometimes, it makes sense to specify a timeout when closin

[jira] [Commented] (KAFKA-9254) Topic level configuration failed

2019-12-01 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16985542#comment-16985542 ] huxihx commented on KAFKA-9254: --- Seems I cannot reproduce it with 2.3.0. Could you retry wi

[jira] [Commented] (KAFKA-9236) Confused log after using CLI scripts to produce messages

2019-11-26 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983211#comment-16983211 ] huxihx commented on KAFKA-9236: --- [~iamabug] It is saying the producer is closing with the s

[jira] [Commented] (KAFKA-9236) Confused log after using CLI scripts to produce messages

2019-11-26 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983195#comment-16983195 ] huxihx commented on KAFKA-9236: --- Could you briefly describe the problem you ran into? > Co

[jira] [Assigned] (KAFKA-9202) serde in ConsoleConsumer with access to headers

2019-11-21 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-9202: - Assignee: huxihx > serde in ConsoleConsumer with access to headers > ---

[jira] [Commented] (KAFKA-9217) Partial partition's log-end-offset is zero

2019-11-21 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16979764#comment-16979764 ] huxihx commented on KAFKA-9217: --- Is it possible that partition 5 has no records at all? >

[jira] [Commented] (KAFKA-9220) TimeoutException when using kafka-preferred-replica-election

2019-11-21 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16979761#comment-16979761 ] huxihx commented on KAFKA-9220: --- That might need a small KIP:) > TimeoutException when usi

[jira] [Resolved] (KAFKA-9208) Flaky Test SslAdminClientIntegrationTest.testCreatePartitions

2019-11-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-9208. --- Resolution: Duplicate > Flaky Test SslAdminClientIntegrationTest.testCreatePartitions > -

[jira] [Assigned] (KAFKA-9157) logcleaner could generate empty segment files after cleaning

2019-11-18 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-9157: - Assignee: huxihx > logcleaner could generate empty segment files after cleaning > --

[jira] [Commented] (KAFKA-9157) logcleaner could generate empty segment files after cleaning

2019-11-17 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976330#comment-16976330 ] huxihx commented on KAFKA-9157: --- [~sbellapu] Do yo still work on this jira? If not, could I

[jira] [Commented] (KAFKA-9150) DescribeGroup uses member assignment as metadata

2019-11-06 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968211#comment-16968211 ] huxihx commented on KAFKA-9150: --- Do not be aware that  David Jacot already takes the jira.

[jira] [Resolved] (KAFKA-9093) NullPointerException in KafkaConsumer with group.instance.id

2019-10-31 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-9093. --- Resolution: Fixed > NullPointerException in KafkaConsumer with group.instance.id > --

[jira] [Assigned] (KAFKA-9069) Flaky Test AdminClientIntegrationTest.testCreatePartitions

2019-10-30 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-9069: - Assignee: huxihx > Flaky Test AdminClientIntegrationTest.testCreatePartitions >

[jira] [Assigned] (KAFKA-9025) ZkSecurityMigrator not working with zookeeper chroot

2019-10-30 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-9025: - Assignee: huxihx > ZkSecurityMigrator not working with zookeeper chroot > --

[jira] [Commented] (KAFKA-9069) Flaky Test AdminClientIntegrationTest.testCreatePartitions

2019-10-30 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962816#comment-16962816 ] huxihx commented on KAFKA-9069: --- [https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/30

[jira] [Commented] (KAFKA-9025) ZkSecurityMigrator not working with zookeeper chroot

2019-10-29 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962659#comment-16962659 ] huxihx commented on KAFKA-9025: --- [~lmairbus] You should explicitly specify the chroot when

[jira] [Assigned] (KAFKA-9093) NullPointerException in KafkaConsumer with group.instance.id

2019-10-24 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-9093: - Assignee: huxihx > NullPointerException in KafkaConsumer with group.instance.id > --

[jira] [Updated] (KAFKA-8946) Single byte header issues WARN logging

2019-10-08 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-8946: -- Component/s: KafkaConnect > Single byte header issues WARN logging > -- > >

[jira] [Updated] (KAFKA-8946) Single byte header issues WARN logging

2019-10-08 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-8946: -- Component/s: (was: KafkaConnect) > Single byte header issues WARN logging > ---

[jira] [Assigned] (KAFKA-8928) Logged producer config does not always match actual config values

2019-10-08 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-8928: - Assignee: huxihx > Logged producer config does not always match actual config values > -

[jira] [Assigned] (KAFKA-8944) Compiler Warning

2019-09-25 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-8944: - Assignee: huxihx > Compiler Warning > > > Key: KAFKA-8944 >

[jira] [Resolved] (KAFKA-8915) Unable to modify partition

2019-09-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-8915. --- Resolution: Not A Problem > Unable to modify partition > -- > > Key:

[jira] [Comment Edited] (KAFKA-8915) Unable to modify partition

2019-09-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933961#comment-16933961 ] huxihx edited comment on KAFKA-8915 at 9/20/19 2:32 AM: Seems it'

[jira] [Commented] (KAFKA-8915) Unable to modify partition

2019-09-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933961#comment-16933961 ] huxihx commented on KAFKA-8915: --- Seems it's a typo. You have to specify `--partitions` inst

[jira] [Assigned] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete

2019-09-16 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-8107: - Assignee: huxihx > Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete >

[jira] [Updated] (KAFKA-8881) Measure thread running time precisely

2019-09-06 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-8881: -- Description: Currently, the code uses `System.currentTimeMillis()` to measure timeout extensively. However, man

[jira] [Updated] (KAFKA-8881) Measure thread running time precisely

2019-09-06 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-8881: -- Description: Currently, the code uses `System.currentTimeMillis()` to measure timeout extensively. However, man

[jira] [Updated] (KAFKA-8881) Measure thread running time precisely

2019-09-06 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-8881: -- Labels: needs-discussion (was: ) > Measure thread running time precisely > ---

[jira] [Created] (KAFKA-8881) Measure thread running time precisely

2019-09-06 Thread huxihx (Jira)
huxihx created KAFKA-8881: - Summary: Measure thread running time precisely Key: KAFKA-8881 URL: https://issues.apache.org/jira/browse/KAFKA-8881 Project: Kafka Issue Type: Improvement Affects Ver

[jira] [Commented] (KAFKA-8838) Allow consumer group tool to work with non-existing consumer groups

2019-09-05 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923917#comment-16923917 ] huxihx commented on KAFKA-8838: --- Do you use the latest version? I cannot reproduce this pro

[jira] [Commented] (KAFKA-8818) CreatePartitions Request protocol documentation

2019-09-05 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923907#comment-16923907 ] huxihx commented on KAFKA-8818: --- Why do you think the array here is invalid? It stores the

[jira] [Commented] (KAFKA-8877) Race condition on partition counter

2019-09-05 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923313#comment-16923313 ] huxihx commented on KAFKA-8877: --- Seems `nextValue` is already removed by [KAFKA-8601|https

[jira] [Assigned] (KAFKA-8876) KafkaBasedLog does not throw exception when some partitions of the topic is offline

2019-09-05 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-8876: - Assignee: huxihx > KafkaBasedLog does not throw exception when some partitions of the topic is > offlin

[jira] [Assigned] (KAFKA-8875) CreateTopic API should check topic existence before replication factor

2019-09-04 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-8875: - Assignee: huxihx > CreateTopic API should check topic existence before replication factor >

[jira] [Resolved] (KAFKA-8719) kafka-console-consumer bypassing sentry evaluations while specifying --partition option

2019-09-01 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-8719. --- Resolution: Cannot Reproduce > kafka-console-consumer bypassing sentry evaluations while specifying > --part

[jira] [Commented] (KAFKA-8719) kafka-console-consumer bypassing sentry evaluations while specifying --partition option

2019-08-29 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16919137#comment-16919137 ] huxihx commented on KAFKA-8719: --- What version did you use?  Options group and partition sho

[jira] [Commented] (KAFKA-8732) specifying a non-existent broker to ./bin/kafka-reassign-partitions.sh leads to reassignment never getting completed.

2019-08-29 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16919121#comment-16919121 ] huxihx commented on KAFKA-8732: --- The issue was already fixed in newer versions where Reassi

[jira] [Issue Comment Deleted] (KAFKA-8719) kafka-console-consumer bypassing sentry evaluations while specifying --partition option

2019-08-29 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-8719: -- Comment: was deleted (was: The issue was already fixed in newer versions where ReassignPartitionsCommand check

[jira] [Commented] (KAFKA-8719) kafka-console-consumer bypassing sentry evaluations while specifying --partition option

2019-08-29 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16919120#comment-16919120 ] huxihx commented on KAFKA-8719: --- The issue was already fixed in newer versions where Reassi

[jira] [Commented] (KAFKA-8718) Not authorized to access topics: [__consumer_offsets] with Apache Kafka 2.3.0

2019-08-29 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16919109#comment-16919109 ] huxihx commented on KAFKA-8718: --- Option `blacklist` was removed by [KAFKA-2983|https://iss

[jira] [Commented] (KAFKA-8801) electLeaderForPartitions redundancy for some success elect partitions

2019-08-15 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908794#comment-16908794 ] huxihx commented on KAFKA-8801: --- Seems it's already fixed in [KAFKA-8286|https://issues.ap

[jira] [Assigned] (KAFKA-8503) AdminClient should ignore retries config if a custom timeout is provided

2019-06-11 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-8503: - Assignee: huxihx > AdminClient should ignore retries config if a custom timeout is provided > --

[jira] [Assigned] (KAFKA-8442) Inconsistent ISR output in topic command when using --bootstrap-server

2019-05-28 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-8442: - Assignee: huxihx > Inconsistent ISR output in topic command when using --bootstrap-server >

[jira] [Commented] (KAFKA-8402) bin/kafka-preferred-replica-election.sh fails if generated json is bigger than 1MB

2019-05-22 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846315#comment-16846315 ] huxihx commented on KAFKA-8402: ---  A possible solution is to throw an exception when the len

[jira] [Assigned] (KAFKA-8338) Improve consumer offset expiration logic to take subscription into account

2019-05-14 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-8338: - Assignee: huxihx > Improve consumer offset expiration logic to take subscription into account >

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

2019-05-10 Thread huxihx (JIRA)
[ 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 neve

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

2019-05-10 Thread huxihx (JIRA)
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: Improv

[jira] [Assigned] (KAFKA-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

2019-04-10 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-8211: - Assignee: huxihx > Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan > -

  1   2   3   4   >