[
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
[
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
[
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
[
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
[
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
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
[
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
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
huxihx created KAFKA-9541:
-
Summary: Flaky Test
DescribeConsumerGroupTest#testDescribeGroupWithShortInitializationTimeout
Key: KAFKA-9541
URL: https://issues.apache.org/jira/browse/KAFKA-9541
Project: Kafka
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
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
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
[
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
[
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
[
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
> --
>
>
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
[
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
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
[
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
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
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
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
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
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
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
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
[
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
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
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
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
[
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
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
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
[
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
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
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
[
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
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 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
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
[
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
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
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
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 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 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
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
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 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 user huxihx closed the pull request at:
https://github.com/apache/kafka/pull/3723
---
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 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 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
[
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
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
[
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
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 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 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
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
[
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
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
[
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
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
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
[
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
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 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
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
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
[
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
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
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
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
[
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
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
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
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
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
[
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
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
[
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
[
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
[
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
99 matches
Mail list logo
