[
https://issues.apache.org/jira/browse/KAFKA-16351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-16351:
Summary: Add groupid field in fetch request (was: add groupid field in
fetch request)
> Add
[
https://issues.apache.org/jira/browse/KAFKA-16351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-16351:
Summary: add groupid field in fetch request (was: add groupid in fetch
request)
> add groupid
zou shengfu created KAFKA-16351:
---
Summary: add groupid in fetch request
Key: KAFKA-16351
URL: https://issues.apache.org/jira/browse/KAFKA-16351
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-14885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14885:
Description:
When a broker has some issues about network, the broker can not connect to
[
https://issues.apache.org/jira/browse/KAFKA-14885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14885:
Description:
When a broker has some issues about network, the broker can not connect to
zou shengfu created KAFKA-14885:
---
Summary: Client can connect to broker and broker can not connect
zookeeper
Key: KAFKA-14885
URL: https://issues.apache.org/jira/browse/KAFKA-14885
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14849:
Description:
# At first, we modify the group.instance.id for consumers wrongly, so different
[
https://issues.apache.org/jira/browse/KAFKA-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14849:
Description:
# At first, we modify the group.instance.id for consumers wrongly, so different
[
https://issues.apache.org/jira/browse/KAFKA-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14849:
Description:
# At first, we modify the group.instance.id for consumers wrongly, so different
[
https://issues.apache.org/jira/browse/KAFKA-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14849:
Description:
# At first, we modify the group.instance.id for consumers wrongly, so different
[
https://issues.apache.org/jira/browse/KAFKA-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14849:
Description:
1. At first, we modify the group.instance.id for consumers wrongly, so
different
[
https://issues.apache.org/jira/browse/KAFKA-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14849:
Attachment: xaa
> Kafka consumers receive INCONSISTENT_GROUP_PROTOCOL error even the
>
[
https://issues.apache.org/jira/browse/KAFKA-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14849:
Attachment: xab
> Kafka consumers receive INCONSISTENT_GROUP_PROTOCOL error even the
>
[
https://issues.apache.org/jira/browse/KAFKA-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14849:
Description:
1. Consumers receive INCONSISTENT_GROUP_PROTOCOL error even the configuration
of
[
https://issues.apache.org/jira/browse/KAFKA-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14849:
Attachment: screenshot-1.png
> Kafka consumers receive INCONSISTENT_GROUP_PROTOCOL error even the
[
https://issues.apache.org/jira/browse/KAFKA-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14849:
Summary: Kafka consumers receive INCONSISTENT_GROUP_PROTOCOL error even the
configuration of all
[
https://issues.apache.org/jira/browse/KAFKA-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14849:
Description: 1. Consumers receive INCONSISTENT_GROUP_PROTOCOL error even
the configuration of
[
https://issues.apache.org/jira/browse/KAFKA-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14849:
Description: 1. Consumers receive
> Kafka consumers receive INCONSISTENT_GROUP_PROTOCOL error
zou shengfu created KAFKA-14849:
---
Summary: Kafka consumers receive INCONSISTENT_GROUP_PROTOCOL error
even the configuration of all consumers are same
Key: KAFKA-14849
URL:
[
https://issues.apache.org/jira/browse/KAFKA-14832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu resolved KAFKA-14832.
-
Resolution: Abandoned
> Thread unsafe for GroupMetadata when persisting metadata
>
[
https://issues.apache.org/jira/browse/KAFKA-14832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14832:
Description:
{code:java}
groupManager.storeGroup(group, groupAssignment, error => {
[
https://issues.apache.org/jira/browse/KAFKA-14832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14832:
Description:
{code:java}
groupManager.storeGroup(group, groupAssignment, error => {
[
https://issues.apache.org/jira/browse/KAFKA-14832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14832:
Description:
{code:java}
groupManager.storeGroup(group, groupAssignment, error => {
[
https://issues.apache.org/jira/browse/KAFKA-14832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14832:
Description:
{code:java}
groupManager.storeGroup(group, groupAssignment, error => {
[
https://issues.apache.org/jira/browse/KAFKA-14832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14832:
Description:
{code:java}
//代码占位符
{code}
groupManager.storeGroup(group, groupAssignment,
[
https://issues.apache.org/jira/browse/KAFKA-14832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14832:
Description:
``` groupManager.storeGroup(group, groupAssignment, error => {
zou shengfu created KAFKA-14832:
---
Summary: Thread unsafe for GroupMetadata
Key: KAFKA-14832
URL: https://issues.apache.org/jira/browse/KAFKA-14832
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-14009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14009:
Affects Version/s: 2.3.1
> Consumers do not reduce rebalancetimeout when consumer use static
[
https://issues.apache.org/jira/browse/KAFKA-14009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-14009:
Description: When consumer use static membership rebalance protocol,
consumer want to reduce
zou shengfu created KAFKA-14009:
---
Summary: Consumers do not reduce rebalancetimeout when consumer
use static membership
Key: KAFKA-14009
URL: https://issues.apache.org/jira/browse/KAFKA-14009
Project:
[
https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286251#comment-17286251
]
zou shengfu commented on KAFKA-12169:
-
"restart with unknown member id", this mean restart the
[
https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-12169:
Description:
Background:
Kafka consumer services run with static membership and cooperative
zou shengfu created KAFKA-12169:
---
Summary: Consumer can not know paritions chage when client leader
restart with static membership protocol
Key: KAFKA-12169
URL: https://issues.apache.org/jira/browse/KAFKA-12169
33 matches
Mail list logo
