[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-15284:
-
Assignee: (was: Kirk True)
> Implement ConsumerGroupProtocolVersionResolver to determine
[
https://issues.apache.org/jira/browse/KAFKA-16639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16639:
--
Priority: Critical (was: Major)
> AsyncKafkaConsumer#close does not send heartbeat to leave group
>
[
https://issues.apache.org/jira/browse/KAFKA-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16819:
--
Labels: consumer-threading-refactor (was: )
> CoordinatorRequestManager seems to return 0ms during
[
https://issues.apache.org/jira/browse/KAFKA-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16819:
--
Component/s: clients
> CoordinatorRequestManager seems to return 0ms during the coordinator discovery
[
https://issues.apache.org/jira/browse/KAFKA-16818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16818:
--
Summary: Move event processing-related tests from ConsumerNetworkThreadTest
to
Kirk True created KAFKA-16818:
-
Summary: Move event-processing tests from
ConsumerNetworkThreadTest to ApplicationEventProcessorTest
Key: KAFKA-16818
URL: https://issues.apache.org/jira/browse/KAFKA-16818
[
https://issues.apache.org/jira/browse/KAFKA-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16578.
---
Resolution: Won't Fix
Most of the {{connect_distributed_test.py}} system tests were fixed, and
[
https://issues.apache.org/jira/browse/KAFKA-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16799:
--
Labels: consumer-threading-refactor (was: )
> NetworkClientDelegate is not backing off if the node
[
https://issues.apache.org/jira/browse/KAFKA-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16799:
--
Component/s: clients
> NetworkClientDelegate is not backing off if the node is not found
>
[
https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847953#comment-17847953
]
Kirk True commented on KAFKA-16272:
---
[~sagarrao]—both of the linked PRs are merged. Can this be marked
[
https://issues.apache.org/jira/browse/KAFKA-16777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16777:
--
Fix Version/s: 3.8.0
> New consumer should throw NoOffsetForPartitionException on continuous poll
>
[
https://issues.apache.org/jira/browse/KAFKA-16758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16758:
--
Fix Version/s: 4.0.0
> Extend Consumer#close with option to leave the group or not
>
[
https://issues.apache.org/jira/browse/KAFKA-16766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16766:
--
Component/s: clients
> New consumer offsetsForTimes timeout exception does not have the proper
>
[
https://issues.apache.org/jira/browse/KAFKA-16764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16764:
--
Component/s: clients
> New consumer should throw InvalidTopicException on poll when invalid topic in
[
https://issues.apache.org/jira/browse/KAFKA-16787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16787:
-
Assignee: Kirk True
> Remove TRACE level logging from AsyncKafkaConsumer hot path
>
[
https://issues.apache.org/jira/browse/KAFKA-16787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16787:
--
Description: There are a few places in the new {{AsyncKafkaConsumer}} in
which we added TRACE-level
Kirk True created KAFKA-16787:
-
Summary: Remove TRACE level logging from AsyncKafkaConsumer hot
path
Key: KAFKA-16787
URL: https://issues.apache.org/jira/browse/KAFKA-16787
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-16787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16787:
--
Labels: consumer-threading-refactor (was: )
> Remove TRACE level logging from AsyncKafkaConsumer hot
[
https://issues.apache.org/jira/browse/KAFKA-16786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16786:
--
Component/s: clients
> New consumer subscribe should not require the deprecated
>
[
https://issues.apache.org/jira/browse/KAFKA-16777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16777:
--
Component/s: clients
> New consumer should throw NoOffsetForPartitionException on continuous poll
>
[
https://issues.apache.org/jira/browse/KAFKA-16764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16764:
--
Fix Version/s: 3.8.0
> New consumer should throw InvalidTopicException on poll when invalid topic in
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15284:
--
Fix Version/s: 4.0.0
> Implement ConsumerGroupProtocolVersionResolver to determine consumer group
>
[
https://issues.apache.org/jira/browse/KAFKA-15697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15697:
--
Fix Version/s: 4.0.0
> Add local assignor and ensure it cannot be used with server side assignor
>
[
https://issues.apache.org/jira/browse/KAFKA-15282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15282:
--
Fix Version/s: 4.0.0
> Implement client support for KIP-848 client-side assignors
>
[
https://issues.apache.org/jira/browse/KAFKA-15279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15279:
--
Fix Version/s: 4.0.0
> Implement client support for KIP-848 client-side assigner RPCs
>
[
https://issues.apache.org/jira/browse/KAFKA-16406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846354#comment-17846354
]
Kirk True commented on KAFKA-16406:
---
[~lianetm]—both PRs are closed. Can this be marked as resolved?
[
https://issues.apache.org/jira/browse/KAFKA-16406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16406:
--
Fix Version/s: 3.8.0
> Split long-running consumer integration test
>
[
https://issues.apache.org/jira/browse/KAFKA-16599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16599:
--
Fix Version/s: 3.8.0
> LegacyConsumer: Always await async commit callbacks in commitSync and close
>
[
https://issues.apache.org/jira/browse/KAFKA-16639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16639:
--
Fix Version/s: 3.8.0
> AsyncKafkaConsumer#close does not send heartbeat to leave group
>
[
https://issues.apache.org/jira/browse/KAFKA-16675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16675:
--
Fix Version/s: 4.0.0
> Move rebalance callback test for positions to callbacks test file
>
[
https://issues.apache.org/jira/browse/KAFKA-16758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16758:
--
Component/s: clients
> Extend Consumer#close with option to leave the group or not
>
[
https://issues.apache.org/jira/browse/KAFKA-16737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16737:
--
Component/s: clients
> Clean up KafkaConsumerTest TODOs enabling tests for new consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16637:
--
Summary: AsyncKafkaConsumer removes offset fetch responses from cache too
aggressively (was: KIP-848
[
https://issues.apache.org/jira/browse/KAFKA-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16637:
--
Priority: Blocker (was: Minor)
> KIP-848 does not work well
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-16427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842817#comment-17842817
]
Kirk True commented on KAFKA-16427:
---
This bug can be triggered with an embarrassingly simple
[
https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16272:
--
Fix Version/s: 3.8.0
(was: 4.0.0)
> Update connect_distributed_test.py to
[
https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16272:
--
Priority: Major (was: Blocker)
> Update connect_distributed_test.py to support KIP-848’s group
[
https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15561:
--
Fix Version/s: 3.8.0
(was: 4.0.0)
> Client support for new SubscriptionPattern
[
https://issues.apache.org/jira/browse/KAFKA-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842530#comment-17842530
]
Kirk True commented on KAFKA-16637:
---
[~chickenchickenlove]—thanks for filing this. There are two
[
https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16290:
--
Priority: Major (was: Critical)
> Investigate propagating subscription state updates via queues
>
[
https://issues.apache.org/jira/browse/KAFKA-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16110:
--
Priority: Major (was: Blocker)
> Implement consumer performance tests
>
[
https://issues.apache.org/jira/browse/KAFKA-16557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16557:
--
Priority: Minor (was: Major)
> Fix OffsetFetchRequestState.toString()
>
[
https://issues.apache.org/jira/browse/KAFKA-16558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16558:
--
Priority: Minor (was: Major)
> Implement HeartbeatRequestState.toStringBase()
>
[
https://issues.apache.org/jira/browse/KAFKA-16623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16623:
--
Description:
When running system tests for the KafkaAsyncConsumer, we occasionally see this
warning:
[
https://issues.apache.org/jira/browse/KAFKA-16623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16623:
--
Description:
When running system tests for the KafkaAsyncConsumer, we occasionally see this
warning:
[
https://issues.apache.org/jira/browse/KAFKA-16623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842453#comment-17842453
]
Kirk True commented on KAFKA-16623:
---
If I add the following code to {{test_fencing_static_consumer}}
[
https://issues.apache.org/jira/browse/KAFKA-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16637:
--
Fix Version/s: 3.8.0
> KIP-848 does not work well
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16637:
--
Component/s: clients
consumer
> KIP-848 does not work well
>
[
https://issues.apache.org/jira/browse/KAFKA-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16637:
--
Labels: kip-848-client-support (was: )
> KIP-848 does not work well
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16637:
-
Assignee: Kirk True
> KIP-848 does not work well
> --
>
>
Kirk True created KAFKA-16642:
-
Summary: Update KafkaConsumerTest to show parameters in test lists
Key: KAFKA-16642
URL: https://issues.apache.org/jira/browse/KAFKA-16642
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-16642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16642:
--
Priority: Minor (was: Major)
> Update KafkaConsumerTest to show parameters in test lists
>
[
https://issues.apache.org/jira/browse/KAFKA-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16576:
--
Priority: Minor (was: Blocker)
> New consumer fails with assert in consumer_test.py’s
[
https://issues.apache.org/jira/browse/KAFKA-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16576:
-
Assignee: (was: Kirk True)
> New consumer fails with assert in consumer_test.py’s
[
https://issues.apache.org/jira/browse/KAFKA-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16460.
---
Resolution: Duplicate
> New consumer times out consuming records in consumer_test.py system test
>
[
https://issues.apache.org/jira/browse/KAFKA-16639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16639:
--
Component/s: clients
consumer
> AsyncKafkaConsumer#close does not send heartbeat to
[
https://issues.apache.org/jira/browse/KAFKA-16609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16609.
---
Reviewer: Lucas Brutschy
Resolution: Fixed
> Update parse_describe_topic to support new topic
Kirk True created KAFKA-16623:
-
Summary: KafkaAsyncConsumer system tests warn about revoking
partitions that weren't previously assigned
Key: KAFKA-16623
URL: https://issues.apache.org/jira/browse/KAFKA-16623
[
https://issues.apache.org/jira/browse/KAFKA-16608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16608:
--
Summary: AsyncKafkaConsumer doesn't honor interrupted thread status on
KafkaConsumer.poll(Duration)
Kirk True created KAFKA-16609:
-
Summary: Update parse_describe_topic to support new topic describe
output
Key: KAFKA-16609
URL: https://issues.apache.org/jira/browse/KAFKA-16609
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16608:
--
Component/s: consumer
> AsyncKafkaConsumer doesn't honour interrupted thread status on
>
[
https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840191#comment-17840191
]
Kirk True commented on KAFKA-16217:
---
[~calvinliu]—I noticed the PR request 15541 is merged, but the
[
https://issues.apache.org/jira/browse/KAFKA-16462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16462.
---
Resolution: Duplicate
> New consumer fails with timeout in security_test.py system test
>
[
https://issues.apache.org/jira/browse/KAFKA-16461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16461:
--
Description:
The {{security_test.py}} system test fails with the following error:
{quote}
* Consumer
[
https://issues.apache.org/jira/browse/KAFKA-16464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16464.
---
Resolution: Duplicate
> New consumer fails with timeout in replication_replica_failure_test.py
[
https://issues.apache.org/jira/browse/KAFKA-16565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16565:
--
Reviewer: Lucas Brutschy
Description:
In {{verifiable_consumer.py}}, the
[
https://issues.apache.org/jira/browse/KAFKA-16461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16461:
--
Reviewer: Lucas Brutschy
> New consumer fails to consume records in security_test.py system test
>
[
https://issues.apache.org/jira/browse/KAFKA-16103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16103:
--
Summary: AsyncKafkaConsumer: Always await async commit callbacks in
commitSync and close (was:
[
https://issues.apache.org/jira/browse/KAFKA-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16577:
--
Description:
The {{consumer_test.py}} system test intermittently fails with the following
error:
[
https://issues.apache.org/jira/browse/KAFKA-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16577:
--
Summary: New consumer fails with stop within allotted timeout in
consumer_test.py system test (was:
[
https://issues.apache.org/jira/browse/KAFKA-16579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16579:
--
Description:
To test the new, asynchronous Kafka {{Consumer}} implementation, we migrated a
slew of
[
https://issues.apache.org/jira/browse/KAFKA-16579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16579:
--
Description:
To test the new, asynchronous Kafka {{Consumer}} implementation, we migrated a
slew of
[
https://issues.apache.org/jira/browse/KAFKA-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16578:
--
Description:
To test the new, asynchronous Kafka {{Consumer}} implementation, we migrated a
slew of
Kirk True created KAFKA-16579:
-
Summary: Revert changes to consumer_rolling_upgrade_test.py for
the new async Consumer
Key: KAFKA-16579
URL: https://issues.apache.org/jira/browse/KAFKA-16579
Project:
[
https://issues.apache.org/jira/browse/KAFKA-16579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16579:
-
Assignee: Philip Nee (was: Kirk True)
> Revert changes to consumer_rolling_upgrade_test.py
Kirk True created KAFKA-16578:
-
Summary: Revert changes to connect_distributed_test.py for the new
async Consumer
Key: KAFKA-16578
URL: https://issues.apache.org/jira/browse/KAFKA-16578
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16576:
--
Labels: flaky-test kip-848-client-support system-tests (was:
kip-848-client-support system-tests)
>
[
https://issues.apache.org/jira/browse/KAFKA-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16577:
--
Labels: flaky-test kip-848-client-support system-tests (was:
kip-848-client-support system-tests)
>
[
https://issues.apache.org/jira/browse/KAFKA-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16577:
--
Description:
The {{consumer_test.py}} system test intermittently fails with the following
error:
[
https://issues.apache.org/jira/browse/KAFKA-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16577:
--
Summary: New consumer fails with stop within allotted timeout in
consumer_test.py’s
Kirk True created KAFKA-16577:
-
Summary: New consumer fails with stop timeout in
consumer_test.py’s test_consumer_bounce system test
Key: KAFKA-16577
URL: https://issues.apache.org/jira/browse/KAFKA-16577
[
https://issues.apache.org/jira/browse/KAFKA-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16576:
--
Description:
The {{consumer_test.py}} system test intermittently fails with the following
error:
Kirk True created KAFKA-16576:
-
Summary: New consumer fails with assert in consumer_test.py’s
test_consumer_failure system test
Key: KAFKA-16576
URL: https://issues.apache.org/jira/browse/KAFKA-16576
[
https://issues.apache.org/jira/browse/KAFKA-16405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16405.
---
Reviewer: Lucas Brutschy
Resolution: Fixed
> Mismatch assignment error when running consumer
[
https://issues.apache.org/jira/browse/KAFKA-16565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16565:
--
Labels: consumer-threading-refactor kip-848-client-support system-tests
(was: )
>
[
https://issues.apache.org/jira/browse/KAFKA-16565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16565:
-
Assignee: Kirk True
> IncrementalAssignmentConsumerEventHandler throws error when attempting
Kirk True created KAFKA-16565:
-
Summary: IncrementalAssignmentConsumerEventHandler throws error
when attempting to remove a partition that isn't assigned
Key: KAFKA-16565
URL:
[
https://issues.apache.org/jira/browse/KAFKA-16555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16555:
--
Issue Type: Bug (was: Task)
> Consumer's RequestState has incorrect logic to determine if inflight
>
[
https://issues.apache.org/jira/browse/KAFKA-16556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16556:
--
Summary: SubscriptionState should not prematurely reset 'pending'
partitions (was: Race condition
[
https://issues.apache.org/jira/browse/KAFKA-15974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15974:
--
Reviewer: Lucas Brutschy (was: Bruno Cadonna)
> Enforce that event processing respects user-provided
[
https://issues.apache.org/jira/browse/KAFKA-16556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16556:
--
Summary: Race condition between ConsumerRebalanceListener and
SubscriptionState causes commit offsets
Kirk True created KAFKA-16558:
-
Summary: Implement HeartbeatRequestState.toStringBase()
Key: KAFKA-16558
URL: https://issues.apache.org/jira/browse/KAFKA-16558
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-16558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16558:
--
Description: The inner class {{HeartbeatRequestState}} does not override
the {{toStringBase()}}
[
https://issues.apache.org/jira/browse/KAFKA-16557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16557:
--
Summary: Fix OffsetFetchRequestState.toString() (was: Fix
CommitRequestManager’s
Kirk True created KAFKA-16557:
-
Summary: Fix CommitRequestManager’s
OffsetFetchRequestState.toString()
Key: KAFKA-16557
URL: https://issues.apache.org/jira/browse/KAFKA-16557
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16556:
--
Description:
There appears to be a race condition between invoking the
{{ConsumerRebalanceListener}}
[
https://issues.apache.org/jira/browse/KAFKA-16556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16556:
-
Assignee: Kirk True
> Race condition between ConsumerRebalanceListener and SubscriptionState
>
Kirk True created KAFKA-16556:
-
Summary: Race condition between ConsumerRebalanceListener and
SubscriptionState
Key: KAFKA-16556
URL: https://issues.apache.org/jira/browse/KAFKA-16556
Project: Kafka
Kirk True created KAFKA-16555:
-
Summary: Consumer's RequestState has incorrect logic to determine
if inflight
Key: KAFKA-16555
URL: https://issues.apache.org/jira/browse/KAFKA-16555
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16507:
--
Component/s: clients
> Add raw record into RecordDeserialisationException
>
1 - 100 of 1935 matches
Mail list logo
