Jeff Kim created KAFKA-16831:
Summary: CoordinatorRuntime should initialize MemoryRecordsBuilder
with max batch size write limit
Key: KAFKA-16831
URL: https://issues.apache.org/jira/browse/KAFKA-16831
[
https://issues.apache.org/jira/browse/KAFKA-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim reassigned KAFKA-16626:
Assignee: Jeff Kim (was: Ritika Reddy)
> Uuid to String for subscribed topic names in
Jeff Kim created KAFKA-16664:
Summary: Re-add EventAccumulator.take(timeout)
Key: KAFKA-16664
URL: https://issues.apache.org/jira/browse/KAFKA-16664
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-16663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-16663:
-
Description: Otherwise, we pile up the number of timer tasks which are
no-ops if replication was
Jeff Kim created KAFKA-16663:
Summary: CoordinatorRuntime write timer tasks should be cancelled
once HWM advances
Key: KAFKA-16663
URL: https://issues.apache.org/jira/browse/KAFKA-16663
Project: Kafka
Jeff Kim created KAFKA-16379:
Summary: add metric to measure time spent in purgatory
Key: KAFKA-16379
URL: https://issues.apache.org/jira/browse/KAFKA-16379
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-16299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim resolved KAFKA-16299.
--
Resolution: Invalid
Not needed. Refer to
Jeff Kim created KAFKA-16317:
Summary: Add event rate in GroupCoordinatorRuntimeMetrics
Key: KAFKA-16317
URL: https://issues.apache.org/jira/browse/KAFKA-16317
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-16307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-16307:
-
Description: The metric does not seem to be accurate, nor reporting metrics
at every interval. Requires
[
https://issues.apache.org/jira/browse/KAFKA-16307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-16307:
-
Summary: fix EventAccumulator thread idle ratio metric (was: investigate
EventAccumulator thread idle
[
https://issues.apache.org/jira/browse/KAFKA-16307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-16307:
-
Description: The metric does not seem to
> investigate EventAccumulator thread idle ratio metric
>
Jeff Kim created KAFKA-16307:
Summary: investigate EventAccumulator thread idle ratio metric
Key: KAFKA-16307
URL: https://issues.apache.org/jira/browse/KAFKA-16307
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-16307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-16307:
-
Description: The metric does not seem to be accurate. Requires
investigation (was: The metric does not
Jeff Kim created KAFKA-16306:
Summary: GroupCoordinatorService logger is not configured
Key: KAFKA-16306
URL: https://issues.apache.org/jira/browse/KAFKA-16306
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-16299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-16299:
-
Description:
In the new coordinator, the classic group response handling is not consistent
compared to
Jeff Kim created KAFKA-16299:
Summary: Classic group error responses should contain a no
generation id and an empty members list
Key: KAFKA-16299
URL: https://issues.apache.org/jira/browse/KAFKA-16299
Jeff Kim created KAFKA-16148:
Summary: Implement GroupMetadataManager#onUnloaded
Key: KAFKA-16148
URL: https://issues.apache.org/jira/browse/KAFKA-16148
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-16106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-16106:
-
Description:
An expire-group-metadata operation generates tombstone records, updates the
`groups`
Jeff Kim created KAFKA-16106:
Summary: group size counters do not reflect the actual sizes when
operations fail
Key: KAFKA-16106
URL: https://issues.apache.org/jira/browse/KAFKA-16106
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-16030:
-
Description: The new coordinator stops loading if the partition goes
offline during load. However, the
Jeff Kim created KAFKA-16030:
Summary: new group coordinator should check if partition goes
offline during load
Key: KAFKA-16030
URL: https://issues.apache.org/jira/browse/KAFKA-16030
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-15981:
-
Description:
Currently, we increment generic group metrics whenever we create a new Group
object when
[
https://issues.apache.org/jira/browse/KAFKA-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-15981:
-
Summary: update Group size only when groups size changes (was: only record
Group state metrics once
[
https://issues.apache.org/jira/browse/KAFKA-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-15981:
-
Summary: only record Group state metrics once per group during load (was:
only record GenericGroup
[
https://issues.apache.org/jira/browse/KAFKA-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-15981:
-
Description:
Currently, we increment generic group metrics whenever we create a new
GenericGroup
[
https://issues.apache.org/jira/browse/KAFKA-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-15981:
-
Description:
Currently, we increment generic group metrics whenever we create a new
GenericGroup
Jeff Kim created KAFKA-15982:
Summary: Move GenericGroup state metrics to
`GroupCoordinatorMetricsShard`
Key: KAFKA-15982
URL: https://issues.apache.org/jira/browse/KAFKA-15982
Project: Kafka
Jeff Kim created KAFKA-15981:
Summary: only record GenericGroup state metrics once per group
during load
Key: KAFKA-15981
URL: https://issues.apache.org/jira/browse/KAFKA-15981
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17791759#comment-17791759
]
Jeff Kim commented on KAFKA-14505:
--
disabled test_transactions
Jeff Kim created KAFKA-15910:
Summary: New group coordinator needs to generate snapshots while
loading
Key: KAFKA-15910
URL: https://issues.apache.org/jira/browse/KAFKA-15910
Project: Kafka
Jeff Kim created KAFKA-15870:
Summary: Move new group coordinator metrics from Yammer to Metrics
Key: KAFKA-15870
URL: https://issues.apache.org/jira/browse/KAFKA-15870
Project: Kafka
Issue
Jeff Kim created KAFKA-15587:
Summary: Limit the number of records per batch in
GroupCoordinatorShard#cleanupGroupMetadata
Key: KAFKA-15587
URL: https://issues.apache.org/jira/browse/KAFKA-15587
Project:
[
https://issues.apache.org/jira/browse/KAFKA-14987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim reassigned KAFKA-14987:
Assignee: Jeff Kim (was: David Jacot)
> Implement Group/Offset expiration
>
Jeff Kim created KAFKA-15207:
Summary: ProducerIdManager#generateProducerId() should return
different error code for newer clients
Key: KAFKA-15207
URL: https://issues.apache.org/jira/browse/KAFKA-15207
[
https://issues.apache.org/jira/browse/KAFKA-15029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-15029:
-
Description:
The producer id block size is currently fixed at 1000. Increasing the size
allows the pid
[
https://issues.apache.org/jira/browse/KAFKA-15029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-15029:
-
Description:
The producer id block size is currently fixed at 1000. Increasing the size
allows the pid
Jeff Kim created KAFKA-15029:
Summary: Make ProducerIdBlock size configurable
Key: KAFKA-15029
URL: https://issues.apache.org/jira/browse/KAFKA-15029
Project: Kafka
Issue Type: Task
[
https://issues.apache.org/jira/browse/KAFKA-14500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim reassigned KAFKA-14500:
Assignee: Jeff Kim
> Implement JoinGroup/SyncGroup APIs
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-14869:
-
Description:
Implement proposed changes in
Jeff Kim created KAFKA-14869:
Summary: txn and group coordinator downgrade foundation
Key: KAFKA-14869
URL: https://issues.apache.org/jira/browse/KAFKA-14869
Project: Kafka
Issue Type: Task
Jeff Kim created KAFKA-14856:
Summary: Next gen group coordinator dynamic configs should be
forward compatible
Key: KAFKA-14856
URL: https://issues.apache.org/jira/browse/KAFKA-14856
Project: Kafka
Jeff Kim created KAFKA-14694:
Summary: RPCProducerIdManager should not wait for a new block
Key: KAFKA-14694
URL: https://issues.apache.org/jira/browse/KAFKA-14694
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640278#comment-17640278
]
Jeff Kim commented on KAFKA-14379:
--
updated from draft to open PR.
> consumer should refresh
[
https://issues.apache.org/jira/browse/KAFKA-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640158#comment-17640158
]
Jeff Kim commented on KAFKA-14379:
--
[~showuon] yes, that is the current plan. can you share what error
Jeff Kim created KAFKA-14407:
Summary: Able to access offset index memory map even after memory
map flag is turned off
Key: KAFKA-14407
URL: https://issues.apache.org/jira/browse/KAFKA-14407
Project:
[
https://issues.apache.org/jira/browse/KAFKA-14372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-14372:
-
Description:
The default replica selector chooses a replica on whether the broker.rack
matches the
[
https://issues.apache.org/jira/browse/KAFKA-14372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-14372:
-
Description:
The default replica selector chooses a replica solely on whether the
broker.rack matches
[
https://issues.apache.org/jira/browse/KAFKA-14372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-14372:
-
Description:
The default replica selector chooses a replica solely on whether the
broker.rack matches
[
https://issues.apache.org/jira/browse/KAFKA-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634565#comment-17634565
]
Jeff Kim commented on KAFKA-14379:
--
sorry for that. got an error when i clicked on create
> consumer
Jeff Kim created KAFKA-14380:
Summary: consumer should refresh preferred read replica on
metadata update
Key: KAFKA-14380
URL: https://issues.apache.org/jira/browse/KAFKA-14380
Project: Kafka
Jeff Kim created KAFKA-14379:
Summary: consumer should refresh preferred read replica on update
metadata
Key: KAFKA-14379
URL: https://issues.apache.org/jira/browse/KAFKA-14379
Project: Kafka
Jeff Kim created KAFKA-14378:
Summary: consumer should refresh preferred read replica on update
metadata
Key: KAFKA-14378
URL: https://issues.apache.org/jira/browse/KAFKA-14378
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-14372:
-
Description: The default replica selector chooses a replica solely on
whether the broker.rack matches
Jeff Kim created KAFKA-14372:
Summary: RackAwareReplicaSelector should choose a replica from the
isr
Key: KAFKA-14372
URL: https://issues.apache.org/jira/browse/KAFKA-14372
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-14334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim reassigned KAFKA-14334:
Assignee: Jeff Kim
> DelayedFetch purgatory not completed when appending as follower
>
Jeff Kim created KAFKA-14334:
Summary: DelayedFetch purgatory not completed when appending as
follower
Key: KAFKA-14334
URL: https://issues.apache.org/jira/browse/KAFKA-14334
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-14075:
-
Description:
In
Jeff Kim created KAFKA-14075:
Summary: Consumer Group deletion does not delete pending
transactional offset commits
Key: KAFKA-14075
URL: https://issues.apache.org/jira/browse/KAFKA-14075
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim reassigned KAFKA-13496:
Assignee: Jeff Kim (was: David Jacot)
> Add reason to LeaveGroupRequest
>
[
https://issues.apache.org/jira/browse/KAFKA-13495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim reassigned KAFKA-13495:
Assignee: Jeff Kim (was: David Jacot)
> Add reason to JoinGroupRequest
>
[
https://issues.apache.org/jira/browse/KAFKA-13451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim reassigned KAFKA-13451:
Assignee: Jeff Kim (was: David Jacot)
> Add reason to JoinGroupRequest and LeaveGroupRequest
>
[
https://issues.apache.org/jira/browse/KAFKA-13007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-13007:
-
Description:
>From
[
https://issues.apache.org/jira/browse/KAFKA-13007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-13007:
-
Description:
>From
[
https://issues.apache.org/jira/browse/KAFKA-13007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-13007:
-
Description:
>From
[
https://issues.apache.org/jira/browse/KAFKA-13007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-13007:
-
Description:
>From
[
https://issues.apache.org/jira/browse/KAFKA-13007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-13007:
-
Description:
>From KafkaAdminClient#getListOffsetsCalls [line of
Jeff Kim created KAFKA-13007:
Summary: KafkaAdminClient getListOffsetsCalls builds cluster
snapshot for every topic partition
Key: KAFKA-13007
URL: https://issues.apache.org/jira/browse/KAFKA-13007
[
https://issues.apache.org/jira/browse/KAFKA-12264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-12264:
-
Description:
Classes that extend BaseRecordBatchBenchmark cannot run with (compression type
= ZSTD,
[
https://issues.apache.org/jira/browse/KAFKA-12264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278737#comment-17278737
]
Jeff Kim commented on KAFKA-12264:
--
[~chia7712] yes, and a separate subclass to run specifically ZSTD +
Jeff Kim created KAFKA-12264:
Summary: JMH BaseRecordBatchBenchmark ZSTD error
Key: KAFKA-12264
URL: https://issues.apache.org/jira/browse/KAFKA-12264
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-10452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10452:
-
Description:
Fetch from follower functionality periodically expires and refreshes preferred
read
Jeff Kim created KAFKA-10452:
Summary: Only expire preferred read replica if a leader is alive
for the topic
Key: KAFKA-10452
URL: https://issues.apache.org/jira/browse/KAFKA-10452
Project: Kafka
Jeff Kim created KAFKA-10328:
Summary: MockConsumer behaves differently than KafkaConsumer
Key: KAFKA-10328
URL: https://issues.apache.org/jira/browse/KAFKA-10328
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-10193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10193:
-
Summary: Add preemption for controller events that have callbacks (was:
Add preemption for
Jeff Kim created KAFKA-10193:
Summary: Add preemption for ControllerEvent that have callbacks
Key: KAFKA-10193
URL: https://issues.apache.org/jira/browse/KAFKA-10193
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10189:
-
Description:
The metric
[
https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10189:
-
Description:
The metric
[
https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10189:
-
Description:
The metric
[
https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10189:
-
Description:
The metric
[
https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10189:
-
Description:
The metric
[
https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10189:
-
Description:
The metric
Jeff Kim created KAFKA-10189:
Summary: Reset metric EventQueueTimeMs
Key: KAFKA-10189
URL: https://issues.apache.org/jira/browse/KAFKA-10189
Project: Kafka
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/KAFKA-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17045928#comment-17045928
]
Jeff Kim commented on KAFKA-9439:
-
`commitTransaction` and `sendOffsetsToTransaction` have already been
[
https://issues.apache.org/jira/browse/KAFKA-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim reassigned KAFKA-9439:
---
Assignee: Jeff Kim
> Add more public API tests for KafkaProducer
>
[
https://issues.apache.org/jira/browse/KAFKA-9479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034881#comment-17034881
]
Jeff Kim commented on KAFKA-9479:
-
[~hachikuji] sounds good. [~ve...@roeim.net] could you submit the
[
https://issues.apache.org/jira/browse/KAFKA-9479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim reassigned KAFKA-9479:
---
Assignee: Jeff Kim
> Describe consumer group --all-groups shows header for each entry
>
86 matches
Mail list logo
