TAO XIAO created KAFKA-7274:
---
Summary: Incorrect subject credential used in inter-broker
communication
Key: KAFKA-7274
URL: https://issues.apache.org/jira/browse/KAFKA-7274
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-4129:
Status: Patch Available (was: Open)
> Processor throw exception when getting channel remote address after c
TAO XIAO created KAFKA-4129:
---
Summary: Processor throw exception when getting channel remote
address after closing the channel
Key: KAFKA-4129
URL: https://issues.apache.org/jira/browse/KAFKA-4129
Project:
[
https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372982#comment-15372982
]
TAO XIAO commented on KAFKA-3950:
-
As only the topics that the users have permission to re
[
https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372705#comment-15372705
]
TAO XIAO commented on KAFKA-3950:
-
How about we still keep the filtering on client side an
[
https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372705#comment-15372705
]
TAO XIAO edited comment on KAFKA-3950 at 7/12/16 11:18 AM:
---
How
[
https://issues.apache.org/jira/browse/KAFKA-3787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-3787:
Status: Patch Available (was: Open)
> Preserve message timestamp in mirror mkaer
>
TAO XIAO created KAFKA-3787:
---
Summary: Preserve message timestamp in mirror mkaer
Key: KAFKA-3787
URL: https://issues.apache.org/jira/browse/KAFKA-3787
Project: Kafka
Issue Type: Bug
Comp
[
https://issues.apache.org/jira/browse/KAFKA-3163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15282310#comment-15282310
]
TAO XIAO commented on KAFKA-3163:
-
[~becket_qin] Thanks. Does the KIP doc in wiki reflect
[
https://issues.apache.org/jira/browse/KAFKA-3163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15282271#comment-15282271
]
TAO XIAO commented on KAFKA-3163:
-
Hi,
Do we have this KIP in the upcoming 0.10.0.0 relea
[
https://issues.apache.org/jira/browse/KAFKA-3409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15198591#comment-15198591
]
TAO XIAO commented on KAFKA-3409:
-
This can also happen when producer is slow and buffer m
TAO XIAO created KAFKA-3409:
---
Summary: Mirror maker hangs indefinitely due to commit
Key: KAFKA-3409
URL: https://issues.apache.org/jira/browse/KAFKA-3409
Project: Kafka
Issue Type: Bug
TAO XIAO created KAFKA-3355:
---
Summary: GetOffsetShell command doesn't work with SASL enabled
Kafka
Key: KAFKA-3355
URL: https://issues.apache.org/jira/browse/KAFKA-3355
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-3206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133580#comment-15133580
]
TAO XIAO commented on KAFKA-3206:
-
This is most likely due to unclean.leader.election.enab
[
https://issues.apache.org/jira/browse/KAFKA-3157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-3157:
Status: Patch Available (was: Open)
> Mirror maker doesn't commit offset with new consumer when there is no
[
https://issues.apache.org/jira/browse/KAFKA-3157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-3157:
Description:
Mirror maker doesn't commit messages with new consumer enabled when messages
are sent to sourc
TAO XIAO created KAFKA-3157:
---
Summary: Mirror maker doesn't commit offset with new consumer when
there is no more messages
Key: KAFKA-3157
URL: https://issues.apache.org/jira/browse/KAFKA-3157
Project: Kafk
[
https://issues.apache.org/jira/browse/KAFKA-2993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2993:
Component/s: producer
> compression-rate-avg always returns 0 even with compression.type being set
> --
[
https://issues.apache.org/jira/browse/KAFKA-2993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2993:
Status: Patch Available (was: Open)
> compression-rate-avg always returns 0 even with compression.type bein
[
https://issues.apache.org/jira/browse/KAFKA-2993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2993:
Affects Version/s: 0.9.0.0
> compression-rate-avg always returns 0 even with compression.type being set
> --
[
https://issues.apache.org/jira/browse/KAFKA-2993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2993:
Summary: compression-rate-avg always returns 0 even with compression.type
being set (was: compression-rate-
TAO XIAO created KAFKA-2993:
---
Summary: compression-rate-avg always returns 0 event with
compression.type being set
Key: KAFKA-2993
URL: https://issues.apache.org/jira/browse/KAFKA-2993
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2281:
Description:
org.apache.kafka.clients.producer.internals.ErrorLoggingCallback is constructed
with byte[] va
[
https://issues.apache.org/jira/browse/KAFKA-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2281:
Attachment: (was: KAFKA-2281.patch)
> org.apache.kafka.clients.producer.internals.ErrorLoggingCallback h
[
https://issues.apache.org/jira/browse/KAFKA-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2281:
Attachment: KAFKA-2281_2015-06-25.patch
> org.apache.kafka.clients.producer.internals.ErrorLoggingCallback h
[
https://issues.apache.org/jira/browse/KAFKA-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2281:
Attachment: (was: KAFKA-2281.patch.1)
> org.apache.kafka.clients.producer.internals.ErrorLoggingCallback
[
https://issues.apache.org/jira/browse/KAFKA-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2281:
Attachment: KAFKA-2281.patch.1
Updated patch. Remove reference to byte[] value when logAsString is false
>
[
https://issues.apache.org/jira/browse/KAFKA-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2281:
Attachment: KAFKA-2281.patch
Patch submitted
> org.apache.kafka.clients.producer.internals.ErrorLoggingCall
[
https://issues.apache.org/jira/browse/KAFKA-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2281:
Status: Patch Available (was: Open)
> org.apache.kafka.clients.producer.internals.ErrorLoggingCallback hold
[
https://issues.apache.org/jira/browse/KAFKA-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2281:
Description:
org.apache.kafka.clients.producer.internals.ErrorLoggingCallback is constructed
with byte[] va
TAO XIAO created KAFKA-2281:
---
Summary:
org.apache.kafka.clients.producer.internals.ErrorLoggingCallback holds
unnecessary byte[] value
Key: KAFKA-2281
URL: https://issues.apache.org/jira/browse/KAFKA-2281
[
https://issues.apache.org/jira/browse/KAFKA-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2048:
Attachment: KAFKA-2048.patch
> java.lang.IllegalMonitorStateException thrown in AbstractFetcherThread when
[
https://issues.apache.org/jira/browse/KAFKA-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2048:
Attachment: (was: KAFKA-2048.patch)
> java.lang.IllegalMonitorStateException thrown in AbstractFetcherTh
[
https://issues.apache.org/jira/browse/KAFKA-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2048:
Status: Patch Available (was: Open)
> java.lang.IllegalMonitorStateException thrown in AbstractFetcherThrea
[
https://issues.apache.org/jira/browse/KAFKA-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2048:
Attachment: KAFKA-2048.patch
Patch submitted. Acquire partitionMapLock explicitly before calling
partitionM
[
https://issues.apache.org/jira/browse/KAFKA-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2048:
Status: Open (was: Patch Available)
> java.lang.IllegalMonitorStateException thrown in AbstractFetcherThrea
[
https://issues.apache.org/jira/browse/KAFKA-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2048:
Attachment: (was: KAFKA-2048.patch)
> java.lang.IllegalMonitorStateException thrown in AbstractFetcherTh
[
https://issues.apache.org/jira/browse/KAFKA-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2048:
Status: Patch Available (was: Open)
> java.lang.IllegalMonitorStateException thrown in AbstractFetcherThrea
[
https://issues.apache.org/jira/browse/KAFKA-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2048:
Attachment: KAFKA-2048.patch
> java.lang.IllegalMonitorStateException thrown in AbstractFetcherThread when
TAO XIAO created KAFKA-2048:
---
Summary: java.lang.IllegalMonitorStateException thrown in
AbstractFetcherThread when handling error returned from simpleConsumer
Key: KAFKA-2048
URL: https://issues.apache.org/jira/browse/K
[
https://issues.apache.org/jira/browse/KAFKA-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14366543#comment-14366543
]
TAO XIAO edited comment on KAFKA-1997 at 3/18/15 2:52 AM:
--
[~beck
[
https://issues.apache.org/jira/browse/KAFKA-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14366543#comment-14366543
]
TAO XIAO commented on KAFKA-1997:
-
[~becket_qin] I think I found a bug in MirrorMaker.scal
[
https://issues.apache.org/jira/browse/KAFKA-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2008:
Description:
The description of num.consumer.fetchers currently shown in consumer config
section of Kafka d
[
https://issues.apache.org/jira/browse/KAFKA-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TAO XIAO updated KAFKA-2008:
Affects Version/s: 0.8.2.0
> Update num.consumer.fetchers description in Kafka documentation
> -
TAO XIAO created KAFKA-2008:
---
Summary: Update num.consumer.fetchers description in Kafka
documentation
Key: KAFKA-2008
URL: https://issues.apache.org/jira/browse/KAFKA-2008
Project: Kafka
Issue Ty
45 matches
Mail list logo
