[GitHub] kafka pull request #3961: KAFKA-5976: RequestChannel.sendResponse should rec...

2017-09-26 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3961 KAFKA-5976: RequestChannel.sendResponse should record correct size for NetworkSend. When TRACE logging is enabled, RequestChannel.sendResponse records incorrect size for `Send` due to the fact that

[GitHub] kafka pull request #4173: KAFKA-6156: Metric tag name should not contain col...

2017-11-02 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/4173 KAFKA-6156: Metric tag name should not contain colons. Windows directory paths often contain colons which are now allowed in yammer metrics. Should convert to its corresponding Unix style path

[GitHub] kafka pull request #4191: KAFKA-6184: report a metric of the lag between the...

2017-11-08 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/4191 KAFKA-6184: report a metric of the lag between the consumer offset ... Add `records-lead` and partition-level `{topic}-{partition}.records-lead-min|avg` for fetcher metrics. @junrao Please

[GitHub] kafka pull request #4326: KAFKA-6362: maybeAutoCommitOffsetsAsync should try...

2017-12-14 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/4326 KAFKA-6362: maybeAutoCommitOffsetsAsync should try to discover coordinator Currently, `maybeAutoCommitOffsetsAsync` may not retry to find out coordinator even after the coordinator goes back to

[GitHub] kafka pull request #4327: KAFKA-6370: KafkaMetricsGroup.toScope should filte...

2017-12-15 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/4327 KAFKA-6370: KafkaMetricsGroup.toScope should filter out tags null value KafkaMetricsGroup.toScope should filter out tags with value of `null` to avoid NullPointerException thrown. *More

[GitHub] kafka pull request #3429: KAFKA-5508: Documentation for altering topics

2017-06-25 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3429 KAFKA-5508: Documentation for altering topics Operations documentation should guide user to employ `kafka-configs.sh` to add/remove configs for a topic. You can merge this pull request into a Git

[GitHub] kafka pull request #3525: KAFKA-5431: cleanSegments should not set length fo...

2017-07-13 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3525 KAFKA-5431: cleanSegments should not set length for cleanable segment files For a compacted topic with preallocate enabled, during log cleaning, LogCleaner.cleanSegments does not have to pre

[GitHub] kafka pull request #3586: KAFKA-5665: Heartbeat thread should use correct in...

2017-07-26 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3586 KAFKA-5665: Heartbeat thread should use correct interruption method to restore status When interrupting the background heartbeat thread, `Thread.interrupted();` is used. Actually

[GitHub] kafka pull request #3613: KAFKA-2360: Extract producer-specific configs out ...

2017-08-02 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3613 KAFKA-2360: Extract producer-specific configs out of the common PerfConfig Separate `batch.size`, `message-size` and `compression-code` from PerfConfig to a newly-created ProducerPerfConfig in order

[GitHub] kafka pull request #3620: KAFKA-5700: Producer should not drop header inform...

2017-08-03 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3620 KAFKA-5700: Producer should not drop header information when splitting batches Producer should not drop header information when splitting batches. This PR also corrects a minor typo in Sender.java

[GitHub] kafka pull request #3586: KAFKA-5665: Heartbeat thread should use correct in...

2017-08-03 Thread huxihx
Github user huxihx closed the pull request at: https://github.com/apache/kafka/pull/3586 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka pull request #3632: KAFKA-5707: TopicCommand and ConfigCommand should ...

2017-08-06 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3632 KAFKA-5707: TopicCommand and ConfigCommand should remove useless `--force` option. TopicCommand and ConfigCommand should remove useless `--force` option. You can merge this pull request into a Git

[GitHub] kafka pull request #3632: KAFKA-5707: TopicCommand and ConfigCommand should ...

2017-08-07 Thread huxihx
Github user huxihx closed the pull request at: https://github.com/apache/kafka/pull/3632 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka pull request #3648: KAFKA-5715: ConsumerGroupCommand should always sho...

2017-08-08 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3648 KAFKA-5715: ConsumerGroupCommand should always show partitions in ascending order Currently, ConsumerGroupCommand shows in ascending order for partitions with active consumer assigned, but failed

[GitHub] kafka pull request #3655: KAFKA-5724: AbstractPartitionAssignor should suppo...

2017-08-11 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3655 KAFKA-5724: AbstractPartitionAssignor should support assignment for topics with non-consecutive partitions Current design does consider the siutation when user creates a topic via KafkaAdminClient

[GitHub] kafka pull request #3682: KAFKA-5745: makeLeader should invoke `convertHWToL...

2017-08-16 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3682 KAFKA-5745: makeLeader should invoke `convertHWToLocalOffsetMetadata` before marking it as leader You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] kafka pull request #3703: KAFKA-5755: KafkaProducer should be refactored to ...

2017-08-20 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3703 KAFKA-5755: KafkaProducer should be refactored to use LogContext With LogContext, each producer log item is automatically prefixed with client id and transactional id. @hachikuji Since a

[GitHub] kafka pull request #3723: KAFKA-5358: Consumer perf tool should count rebala...

2017-08-22 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3723 KAFKA-5358: Consumer perf tool should count rebalance time. You can merge this pull request into a Git repository by running: $ git pull https://github.com/huxihx/kafka KAFKA-5358

[GitHub] kafka pull request #3188: KAFKA-5358: Consumer perf tool should count rebala...

2017-08-22 Thread huxihx
Github user huxihx closed the pull request at: https://github.com/apache/kafka/pull/3188 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka pull request #3188: KAFKA-5358: Consumer perf tool should count rebala...

2017-09-05 Thread huxihx
GitHub user huxihx reopened a pull request: https://github.com/apache/kafka/pull/3188 KAFKA-5358: Consumer perf tool should count rebalance time. Added 'join.group.ms' for new consumer to calculate the time of joining group. @hachikuji Please review the PR. Th

[GitHub] kafka pull request #3723: KAFKA-5358: Consumer perf tool should count rebala...

2017-09-05 Thread huxihx
Github user huxihx closed the pull request at: https://github.com/apache/kafka/pull/3723 ---

[GitHub] kafka pull request #3798: KAFKA-5841: AbstractIndex should offer `makeReadOn...

2017-09-05 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3798 KAFKA-5841: AbstractIndex should offer `makeReadOnly` method AbstractIndex should offer `makeReadOnly` method that changed the underlying MappedByteBuffer read-only. You can merge this pull request

[GitHub] kafka pull request #3866: KAFKA-5874: TopicCommand should check at least one...

2017-09-14 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3866 KAFKA-5874: TopicCommand should check at least one parameter is given... When altering topics, TopicCommand should ensure that at least one of parameters in `partitions`, `config` or `delete-config

[GitHub] kafka pull request #3223: KAFKA-5098: KafkaProducer.send() should validate t...

2017-06-02 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3223 KAFKA-5098: KafkaProducer.send() should validate topic name before sending KafkaProducer.send() should check topic name before sending the record. You can merge this pull request into a Git

[GitHub] kafka pull request #3265: KAFKA-5405: Request log should log throttle time

2017-06-07 Thread huxihx
GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3265 KAFKA-5405: Request log should log throttle time Record `apiThrottleTime` in RequestChannel. @junrao A trivial change. Please review. Thanks. You can merge this pull request into a Git

[jira] [Created] (KAFKA-7665) Replace BaseConsumerRecord with ConsumerRecord in MM

2018-11-20 Thread huxihx (JIRA)
huxihx created KAFKA-7665: - Summary: Replace BaseConsumerRecord with ConsumerRecord in MM Key: KAFKA-7665 URL: https://issues.apache.org/jira/browse/KAFKA-7665 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7705) Update javadoc for default value of delivery.timeout.ms

2018-12-03 Thread huxihx (JIRA)
huxihx created KAFKA-7705: - Summary: Update javadoc for default value of delivery.timeout.ms Key: KAFKA-7705 URL: https://issues.apache.org/jira/browse/KAFKA-7705 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-7765) IdleExpiryManager should not passively close socket used by controller

2018-12-21 Thread huxihx (JIRA)
huxihx created KAFKA-7765: - Summary: IdleExpiryManager should not passively close socket used by controller Key: KAFKA-7765 URL: https://issues.apache.org/jira/browse/KAFKA-7765 Project: Kafka

[jira] [Created] (KAFKA-7779) Avoid unnecessary loop iteration in leastLoadedNode

2019-01-02 Thread huxihx (JIRA)
huxihx created KAFKA-7779: - Summary: Avoid unnecessary loop iteration in leastLoadedNode Key: KAFKA-7779 URL: https://issues.apache.org/jira/browse/KAFKA-7779 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7801) TopicCommand should not be able to alter transaction topic partition count

2019-01-08 Thread huxihx (JIRA)
huxihx created KAFKA-7801: - Summary: TopicCommand should not be able to alter transaction topic partition count Key: KAFKA-7801 URL: https://issues.apache.org/jira/browse/KAFKA-7801 Project: Kafka

[jira] [Reopened] (KAFKA-7141) kafka-consumer-group doesn't describe existing group

2018-07-10 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reopened KAFKA-7141: --- Assignee: huxihx > kafka-consumer-group doesn't describe existi

[jira] [Resolved] (KAFKA-6370) MirrorMakerIntegrationTest#testCommaSeparatedRegex may fail due to NullPointerException

2018-02-01 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-6370. --- Resolution: Cannot Reproduce Although it's harmless to add some defensive checks, this issue should hav

[jira] [Created] (KAFKA-6550) UpdateMetadataRequest should be lazily created

2018-02-09 Thread huxihx (JIRA)
huxihx created KAFKA-6550: - Summary: UpdateMetadataRequest should be lazily created Key: KAFKA-6550 URL: https://issues.apache.org/jira/browse/KAFKA-6550 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

2018-02-25 Thread huxihx (JIRA)
huxihx created KAFKA-6592: - Summary: NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer` Key: KAFKA-6592 URL: https://issues.apache.org/jira/browse/KAFKA-6592

[jira] [Resolved] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

2018-03-01 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-6592. --- Resolution: Duplicate Seems it's a duplicate of [KAFKA-4831|https://issues.apache.org/jira/browse/KAFKA

[jira] [Created] (KAFKA-6663) Expression for GlobalKTable is not correct

2018-03-15 Thread huxihx (JIRA)
huxihx created KAFKA-6663: - Summary: Expression for GlobalKTable is not correct Key: KAFKA-6663 URL: https://issues.apache.org/jira/browse/KAFKA-6663 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6731) waitOnState waits for the wrong state instead of the target one

2018-04-01 Thread huxihx (JIRA)
huxihx created KAFKA-6731: - Summary: waitOnState waits for the wrong state instead of the target one Key: KAFKA-6731 URL: https://issues.apache.org/jira/browse/KAFKA-6731 Project: Kafka Issue Type

[jira] [Created] (KAFKA-6814) Bad exception message for GroupIdNotFoundException/GroupNotEmptyException

2018-04-22 Thread huxihx (JIRA)
huxihx created KAFKA-6814: - Summary: Bad exception message for GroupIdNotFoundException/GroupNotEmptyException Key: KAFKA-6814 URL: https://issues.apache.org/jira/browse/KAFKA-6814 Project: Kafka

[jira] [Created] (KAFKA-7279) partitionsFor implicitly creates topic for the existent topic

2018-08-12 Thread huxihx (JIRA)
huxihx created KAFKA-7279: - Summary: partitionsFor implicitly creates topic for the existent topic Key: KAFKA-7279 URL: https://issues.apache.org/jira/browse/KAFKA-7279 Project: Kafka Issue Type

[jira] [Created] (KAFKA-7354) Fix IdlePercent and NetworkProcessorAvgIdlePercent metric calculation

2018-08-28 Thread huxihx (JIRA)
huxihx created KAFKA-7354: - Summary: Fix IdlePercent and NetworkProcessorAvgIdlePercent metric calculation Key: KAFKA-7354 URL: https://issues.apache.org/jira/browse/KAFKA-7354 Project: Kafka Issue

[jira] [Created] (KAFKA-5976) RequestChannel.sendReponse records incorrect size for NetworkSend with TRACE logging

2017-09-26 Thread huxihx (JIRA)
huxihx created KAFKA-5976: - Summary: RequestChannel.sendReponse records incorrect size for NetworkSend with TRACE logging Key: KAFKA-5976 URL: https://issues.apache.org/jira/browse/KAFKA-5976 Project: Kafka

[jira] [Created] (KAFKA-6219) Inconsistent behavior for kafka-consumer-groups with ACL enabled

2017-11-15 Thread huxihx (JIRA)
huxihx created KAFKA-6219: - Summary: Inconsistent behavior for kafka-consumer-groups with ACL enabled Key: KAFKA-6219 URL: https://issues.apache.org/jira/browse/KAFKA-6219 Project: Kafka Issue Type

[jira] [Created] (KAFKA-6341) 'networkThreadTimeNanos' in KafkaChannel is not thread safe

2017-12-11 Thread huxihx (JIRA)
huxihx created KAFKA-6341: - Summary: 'networkThreadTimeNanos' in KafkaChannel is not thread safe Key: KAFKA-6341 URL: https://issues.apache.org/jira/browse/KAFKA-6341 Project: Kafka Issue

[jira] [Resolved] (KAFKA-6341) 'networkThreadTimeNanos' in KafkaChannel is not thread safe

2017-12-11 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-6341. --- Resolution: Not A Bug > 'networkThreadTimeNanos' in KafkaChannel is no

[jira] [Created] (KAFKA-6355) transient failure in org.apache.kafka.streams.integration.EosIntegrationTest.shouldBeAbleToRunWithTwoSubtopologies

2017-12-12 Thread huxihx (JIRA)
huxihx created KAFKA-6355: - Summary: transient failure in org.apache.kafka.streams.integration.EosIntegrationTest.shouldBeAbleToRunWithTwoSubtopologies Key: KAFKA-6355 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Resolved] (KAFKA-4767) KafkaProducer is not joining its IO thread properly

2017-12-17 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-4767. --- Resolution: Fixed already fixed in another jira. > KafkaProducer is not joining its IO thread prope

[jira] [Created] (KAFKA-6425) Calculating cleanBytes in LogToClean might not be correct

2018-01-05 Thread huxihx (JIRA)
huxihx created KAFKA-6425: - Summary: Calculating cleanBytes in LogToClean might not be correct Key: KAFKA-6425 URL: https://issues.apache.org/jira/browse/KAFKA-6425 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6429) dirtyNonActiveSegments in `cleanableOffsets` should only be created when log.cleaner.min.compaction.lag.ms > 0

2018-01-06 Thread huxihx (JIRA)
huxihx created KAFKA-6429: - Summary: dirtyNonActiveSegments in `cleanableOffsets` should only be created when log.cleaner.min.compaction.lag.ms > 0 Key: KAFKA-6429 URL: https://issues.apache.org/jira/browse/KAFKA-6

[jira] [Resolved] (KAFKA-8161) Comma conflict when run script bin/kafka-configs.sh with config 'follower.replication.throttled.replicas'

2019-04-10 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-8161. --- Resolution: Not A Problem > Comma conflict when run script bin/kafka-configs.sh with con

[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

[jira] [Commented] (KAFKA-2526) Console Producer / Consumer's serde config is not working

2017-06-09 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045296#comment-16045296 ] huxihx commented on KAFKA-2526: --- [~guozhang] No, I am thinking [~mgharat] is workin

[jira] [Commented] (KAFKA-5418) ZkUtils.getAllPartitions() may fail if a topic is marked for deletion

2017-06-09 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045321#comment-16045321 ] huxihx commented on KAFKA-5418: --- Is it a duplicate of [KAFKA-1019|h

[jira] [Commented] (KAFKA-5432) producer and consumer SocketTimeoutException

2017-06-12 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047390#comment-16047390 ] huxihx commented on KAFKA-5432: --- Are there any changes before observing these except

[jira] [Commented] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

2017-06-13 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047561#comment-16047561 ] huxihx commented on KAFKA-5007: --- [~junrao] is it possible that it 's caused by

[jira] [Updated] (KAFKA-5432) producer and consumer SocketTimeoutException

2017-06-13 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-5432: -- Component/s: (was: KafkaConnect) > producer and consumer SocketTimeoutExcept

[jira] [Commented] (KAFKA-5432) producer and consumer SocketTimeoutException

2017-06-13 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047569#comment-16047569 ] huxihx commented on KAFKA-5432: --- Seems it is a duplicate of [KAFKA-5007|h

[jira] [Commented] (KAFKA-5431) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

2017-06-13 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047637#comment-16047637 ] huxihx commented on KAFKA-5431: --- Could you run command below to see whether there exis

[jira] [Comment Edited] (KAFKA-5431) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

2017-06-13 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047637#comment-16047637 ] huxihx edited comment on KAFKA-5431 at 6/13/17 9:25 AM: Could

[jira] [Commented] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

2017-06-13 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16048605#comment-16048605 ] huxihx commented on KAFKA-5007: --- [~joseph.alias...@gmail

[jira] [Commented] (KAFKA-5432) producer and consumer SocketTimeoutException

2017-06-13 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16048615#comment-16048615 ] huxihx commented on KAFKA-5432: --- I might not see rolling new log segment as an indicato

[jira] [Commented] (KAFKA-5444) Producer.send() will hang 8+ hours

2017-06-13 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16048674#comment-16048674 ] huxihx commented on KAFKA-5444: --- Is it a duplicate of [KAFKA-3552|h

[jira] [Commented] (KAFKA-5444) Producer.send() will hang 8+ hours

2017-06-14 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049787#comment-16049787 ] huxihx commented on KAFKA-5444: --- Is it possible to try using the new producer? And why

[jira] [Created] (KAFKA-5560) LogManager should be able to create new logs based on free disk space

2017-07-06 Thread huxihx (JIRA)
huxihx created KAFKA-5560: - Summary: LogManager should be able to create new logs based on free disk space Key: KAFKA-5560 URL: https://issues.apache.org/jira/browse/KAFKA-5560 Project: Kafka Issue

[jira] [Resolved] (KAFKA-5582) Log compaction with preallocation enabled does not trim segments

2017-07-20 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-5582. --- Resolution: Duplicate > Log compaction with preallocation enabled does not trim segme

[jira] [Created] (KAFKA-5641) Metadata request should be allowed to send no regardless of value for max.in.flight.requests.per.connection

2017-07-25 Thread huxihx (JIRA)
huxihx created KAFKA-5641: - Summary: Metadata request should be allowed to send no regardless of value for max.in.flight.requests.per.connection Key: KAFKA-5641 URL: https://issues.apache.org/jira/browse/KAFKA-5641

[jira] [Created] (KAFKA-5665) Incorrect interruption invoking method used for Heartbeat thread

2017-07-26 Thread huxihx (JIRA)
huxihx created KAFKA-5665: - Summary: Incorrect interruption invoking method used for Heartbeat thread Key: KAFKA-5665 URL: https://issues.apache.org/jira/browse/KAFKA-5665 Project: Kafka Issue

[jira] [Resolved] (KAFKA-5641) Metadata request should always be allowed to send no regardless of value for max.in.flight.requests.per.connection

2017-08-02 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-5641. --- Resolution: Not A Problem > Metadata request should always be allowed to send no regardless of value

[jira] [Created] (KAFKA-5700) producer missed header information when splitting batches

2017-08-03 Thread huxihx (JIRA)
huxihx created KAFKA-5700: - Summary: producer missed header information when splitting batches Key: KAFKA-5700 URL: https://issues.apache.org/jira/browse/KAFKA-5700 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-5665) Incorrect interruption invoking method used for Heartbeat thread

2017-08-03 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-5665. --- Resolution: Not A Bug > Incorrect interruption invoking method used for Heartbeat thr

[jira] [Created] (KAFKA-5707) Remove useless `--force` option for both TopicCommand and ConfigCommand

2017-08-06 Thread huxihx (JIRA)
huxihx created KAFKA-5707: - Summary: Remove useless `--force` option for both TopicCommand and ConfigCommand Key: KAFKA-5707 URL: https://issues.apache.org/jira/browse/KAFKA-5707 Project: Kafka

[jira] [Resolved] (KAFKA-5700) producer missed header information when splitting batches

2017-08-06 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-5700. --- Resolution: Fixed > producer missed header information when splitting batc

[jira] [Resolved] (KAFKA-5707) Remove useless `--force` option for both TopicCommand and ConfigCommand

2017-08-07 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-5707. --- Resolution: Not A Bug For the sake of compatibility, just keep `--force` in both classes. Closed this jira

[jira] [Created] (KAFKA-5715) ConsumerGroupCommand failed to show in ascending order for partitions without consumers

2017-08-08 Thread huxihx (JIRA)
huxihx created KAFKA-5715: - Summary: ConsumerGroupCommand failed to show in ascending order for partitions without consumers Key: KAFKA-5715 URL: https://issues.apache.org/jira/browse/KAFKA-5715 Project

[jira] [Reopened] (KAFKA-5744) ShellTest: add tests for attempting to run nonexistent program, error return

2017-08-20 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reopened KAFKA-5744: --- [~cmccabe] On Mac OS, `head -c 0 ` fails with the error "illegal byte count -- 0" instead of &qu

[jira] [Resolved] (KAFKA-5753) ShellTest.testRunProgramWithErrorReturn fails locally

2017-08-20 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-5753. --- Resolution: Duplicate > ShellTest.testRunProgramWithErrorReturn fails loca

[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 specify

[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

[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 > -- > >

[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

[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] [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.rete

[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

[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 ConsumerPerforma

[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 KafkaLog4jAppen

[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 val

[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 h

[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.testCreatePartiti

[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

[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

[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

[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] [Commented] (KAFKA-5296) Unable to write to some partitions of newly created topic in 10.2

2017-06-02 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16035862#comment-16035862 ] huxihx commented on KAFKA-5296: --- [~asaikia] Do you mean directories for some partit

[jira] [Commented] (KAFKA-5287) Messages getting repeated in kafka

2017-06-02 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16035864#comment-16035864 ] huxihx commented on KAFKA-5287: --- Do you ensure you check status for the same g

[jira] [Commented] (KAFKA-5262) Can't find some consumer group information

2017-06-02 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16035865#comment-16035865 ] huxihx commented on KAFKA-5262: --- Does your client code commit offsets? Besides, a comp

[jira] [Assigned] (KAFKA-5098) KafkaProducer.send() blocks and generates TimeoutException if topic name has illegal char

2017-06-02 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-5098: - Assignee: huxihx > KafkaProducer.send() blocks and generates TimeoutException if topic name

[jira] [Assigned] (KAFKA-5405) Request log should log throttle time

2017-06-07 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-5405: - Assignee: huxihx > Request log should log throttle t

[jira] [Commented] (KAFKA-5402) JmxReporter Fetch metrics for kafka.server should not be created when client quotas are not enabled

2017-06-07 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16042069#comment-16042069 ] huxihx commented on KAFKA-5402: --- Is it a duplicate of [KAFKA-3980|h

[jira] [Commented] (KAFKA-5406) NoNodeException result in rebalance failed

2017-06-07 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16042077#comment-16042077 ] huxihx commented on KAFKA-5406: --- Maybe could estimate the total time period for the net

[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