[
https://issues.apache.org/jira/browse/KAFKA-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-15174.
Resolution: Fixed
> Ensure the correct thread is executing the callba
Philip Nee created KAFKA-15865:
--
Summary: Ensure consumer.poll() execute autocommit callback
Key: KAFKA-15865
URL: https://issues.apache.org/jira/browse/KAFKA-15865
Project: Kafka
Issue Type
Philip Nee created KAFKA-15866:
--
Summary: Refactor OffsetFetchRequestState Error handling to be
more consistent with OffsetCommitRequestState
Key: KAFKA-15866
URL: https://issues.apache.org/jira/browse/KAFKA-15866
Philip Nee created KAFKA-15867:
--
Summary: Should ConsumerNetworkThread wrap the exception and
notify the polling thread?
Key: KAFKA-15867
URL: https://issues.apache.org/jira/browse/KAFKA-15867
Project
[
https://issues.apache.org/jira/browse/KAFKA-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-15836.
Resolution: Fixed
PR merged.
> KafkaConsumer subscribes to multiple topics does not resp
Philip Nee created KAFKA-15872:
--
Summary: Investigate autocommit retry logic
Key: KAFKA-15872
URL: https://issues.apache.org/jira/browse/KAFKA-15872
Project: Kafka
Issue Type: Sub-task
Philip Nee created KAFKA-15913:
--
Summary: Remove excessive use of spy in CosumerTestBuilder
Key: KAFKA-15913
URL: https://issues.apache.org/jira/browse/KAFKA-15913
Project: Kafka
Issue Type
Philip Nee created KAFKA-15942:
--
Summary: Implement ConsumerInterceptor
Key: KAFKA-15942
URL: https://issues.apache.org/jira/browse/KAFKA-15942
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-16474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-16474.
Resolution: Fixed
Ran the test several times, the client log also looks fine
Philip Nee created KAFKA-16778:
--
Summary: AsyncKafkaConsumer fetcher might occasionally try to
fetch to a revoked partition
Key: KAFKA-16778
URL: https://issues.apache.org/jira/browse/KAFKA-16778
Philip Nee created KAFKA-16799:
--
Summary: NetworkClientDelegate is not backing off if the node is
not found
Key: KAFKA-16799
URL: https://issues.apache.org/jira/browse/KAFKA-16799
Project: Kafka
Philip Nee created KAFKA-16819:
--
Summary: CoordinatorRequestManager seems to return 0ms during the
coordinator discovery
Key: KAFKA-16819
URL: https://issues.apache.org/jira/browse/KAFKA-16819
Project
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-16160.
Resolution: Cannot Reproduce
> AsyncKafkaConsumer is trying to connect to a disconnected node
Philip Nee created KAFKA-17188:
--
Summary: LoginManager ctro might throw an exception causing login
and loginCallbackHandler not being closed properly
Key: KAFKA-17188
URL: https://issues.apache.org/jira/browse/KAFKA
[
https://issues.apache.org/jira/browse/KAFKA-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-16819.
Resolution: Fixed
> CoordinatorRequestManager seems to return 0ms during the coordina
Philip Nee created KAFKA-15946:
--
Summary: AsyncKafkaConsumer should retry commits on the
application thread instead of autoretry
Key: KAFKA-15946
URL: https://issues.apache.org/jira/browse/KAFKA-15946
Philip Nee created KAFKA-15948:
--
Summary: Refactor AsyncKafkaConsumer shutdown
Key: KAFKA-15948
URL: https://issues.apache.org/jira/browse/KAFKA-15948
Project: Kafka
Issue Type: Bug
Philip Nee created KAFKA-15993:
--
Summary: Enable integration tests that relies on rebalance listener
Key: KAFKA-15993
URL: https://issues.apache.org/jira/browse/KAFKA-15993
Project: Kafka
Issue
Philip Nee created KAFKA-16019:
--
Summary: Some of the tests in PlaintextConsumer can't seem to
deterministically invokes and verify the consumer callback
Key: KAFKA-16019
URL: https://issues.apache.org/jira/b
Philip Nee created KAFKA-16022:
--
Summary: AsyncKafkaConsumer sometimes complains "No current
assignment for partition {}"
Key: KAFKA-16022
URL: https://issues.apache.org/jira/browse/KAFKA-16022
Philip Nee created KAFKA-16023:
--
Summary: PlaintextConsumerTest needs to wait for reconciliation to
complete before proceeding
Key: KAFKA-16023
URL: https://issues.apache.org/jira/browse/KAFKA-16023
Philip Nee created KAFKA-16024:
--
Summary: SaslPlaintextConsumerTest#testCoordinatorFailover is flaky
Key: KAFKA-16024
URL: https://issues.apache.org/jira/browse/KAFKA-16024
Project: Kafka
Issue
Philip Nee created KAFKA-16026:
--
Summary: AsyncConsumer does not send a poll event to the
background thread
Key: KAFKA-16026
URL: https://issues.apache.org/jira/browse/KAFKA-16026
Project: Kafka
Philip Nee created KAFKA-16027:
--
Summary: Refactor MetadataTest#testUpdatePartitionLeadership
Key: KAFKA-16027
URL: https://issues.apache.org/jira/browse/KAFKA-16027
Project: Kafka
Issue Type
Philip Nee created KAFKA-16034:
--
Summary: AsyncKafkaConsumer will get Invalid Request error when
trying to rejoin on fenced/unknown member Id
Key: KAFKA-16034
URL: https://issues.apache.org/jira/browse/KAFKA-16034
[
https://issues.apache.org/jira/browse/KAFKA-15948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-15948.
Assignee: Philip Nee (was: Phuc Hong Tran)
Resolution: Fixed
> Refactor AsyncKafkaConsu
[
https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-15250.
Fix Version/s: (was: 3.8.0)
Resolution: Fixed
> DefaultBackgroundThread is runn
Philip Nee created KAFKA-16113:
--
Summary: AsyncKafkaConsumer: Add missing offset commit metrics
Key: KAFKA-16113
URL: https://issues.apache.org/jira/browse/KAFKA-16113
Project: Kafka
Issue Type
Philip Nee created KAFKA-16115:
--
Summary: AsyncKafkaConsumer: Add missing heartbeat metrics
Key: KAFKA-16115
URL: https://issues.apache.org/jira/browse/KAFKA-16115
Project: Kafka
Issue Type
Philip Nee created KAFKA-16116:
--
Summary: AsyncKafkaConsumer: Add missing rebalance metrics
Key: KAFKA-16116
URL: https://issues.apache.org/jira/browse/KAFKA-16116
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-16112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-16112.
Resolution: Fixed
These are the results of this ticket
|KAFKA-16113|
|KAFKA-16116|
|KAFKA
Philip Nee created KAFKA-16159:
--
Summary: Prune excessive logging from Telemetry Reporter
Key: KAFKA-16159
URL: https://issues.apache.org/jira/browse/KAFKA-16159
Project: Kafka
Issue Type: Task
Philip Nee created KAFKA-16160:
--
Summary: AsyncKafkaConsumer is trying to connect to a disconnected
note in a tight loop
Key: KAFKA-16160
URL: https://issues.apache.org/jira/browse/KAFKA-16160
Project
[
https://issues.apache.org/jira/browse/KAFKA-16113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-16113.
Resolution: Fixed
> AsyncKafkaConsumer: Add missing offset commit metr
[
https://issues.apache.org/jira/browse/KAFKA-16115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-16115.
Resolution: Fixed
> AsyncKafkaConsumer: Add missing heartbeat metr
[
https://issues.apache.org/jira/browse/KAFKA-16116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-16116.
Resolution: Fixed
> AsyncKafkaConsumer: Add missing rebalance metr
Philip Nee created KAFKA-16390:
--
Summary: consumer_bench_test.py failed using AsyncKafkaConsumer
Key: KAFKA-16390
URL: https://issues.apache.org/jira/browse/KAFKA-16390
Project: Kafka
Issue
Philip Nee created KAFKA-16405:
--
Summary: Mismatch assignment error when running consumer rolling
upgrade system tests
Key: KAFKA-16405
URL: https://issues.apache.org/jira/browse/KAFKA-16405
Project
Philip Nee created KAFKA-16433:
--
Summary: beginningOffsets and offsetsForTimes don't behave
consistently when providing a zero timeout
Key: KAFKA-16433
URL: https://issues.apache.org/jira/browse/KAFKA-
Philip Nee created KAFKA-16474:
--
Summary: AsyncKafkaConsumer might rapidly send out successive
heartbeat causing partitions getting revoked
Key: KAFKA-16474
URL: https://issues.apache.org/jira/browse/KAFKA-16474
[
https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-16389.
Resolution: Fixed
> consumer_test.py’s test_valid_assignment fails with new consu
[
https://issues.apache.org/jira/browse/KAFKA-16579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-16579.
Resolution: Fixed
> Revert changes to consumer_rolling_upgrade_test.py for the new async Consu
Philip Nee created KAFKA-14196:
--
Summary: Flaky OffsetValidationTest seems to indicate potential
duplication issue during rebalance
Key: KAFKA-14196
URL: https://issues.apache.org/jira/browse/KAFKA-14196
Philip Nee created KAFKA-14246:
--
Summary: Refactor KafkaConsumer Threading Model
Key: KAFKA-14246
URL: https://issues.apache.org/jira/browse/KAFKA-14246
Project: Kafka
Issue Type: Improvement
Philip Nee created KAFKA-14247:
--
Summary: Implement EventHandler interface and DefaultEventHandler
Key: KAFKA-14247
URL: https://issues.apache.org/jira/browse/KAFKA-14247
Project: Kafka
Issue
Philip Nee created KAFKA-14252:
--
Summary: Create background thread skeleton
Key: KAFKA-14252
URL: https://issues.apache.org/jira/browse/KAFKA-14252
Project: Kafka
Issue Type: Sub-task
Philip Nee created KAFKA-14264:
--
Summary: Create a coordinator class for the new implementation
Key: KAFKA-14264
URL: https://issues.apache.org/jira/browse/KAFKA-14264
Project: Kafka
Issue Type
Philip Nee created KAFKA-14274:
--
Summary: Implement fetching logic
Key: KAFKA-14274
URL: https://issues.apache.org/jira/browse/KAFKA-14274
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-14252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-14252.
Resolution: Fixed
> Create background thread skele
Philip Nee created KAFKA-14438:
--
Summary: Stop supporting empty consumer groupId
Key: KAFKA-14438
URL: https://issues.apache.org/jira/browse/KAFKA-14438
Project: Kafka
Issue Type: Task
Philip Nee created KAFKA-14468:
--
Summary: Refactor Commit Logic
Key: KAFKA-14468
URL: https://issues.apache.org/jira/browse/KAFKA-14468
Project: Kafka
Issue Type: Sub-task
Components
Philip Nee created KAFKA-14761:
--
Summary: Integration Tests for the New Consumer Implementation
Key: KAFKA-14761
URL: https://issues.apache.org/jira/browse/KAFKA-14761
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-14752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-14752.
Resolution: Fixed
> improve kafka examples under examples pack
[
https://issues.apache.org/jira/browse/KAFKA-14752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee reopened KAFKA-14752:
> improve kafka examples under examples pack
[
https://issues.apache.org/jira/browse/KAFKA-14753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-14753.
Resolution: Fixed
> improve producer under example pack
[
https://issues.apache.org/jira/browse/KAFKA-14754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-14754.
Resolution: Fixed
> improve consumer under example pack
Philip Nee created KAFKA-14875:
--
Summary: Implement Wakeup()
Key: KAFKA-14875
URL: https://issues.apache.org/jira/browse/KAFKA-14875
Project: Kafka
Issue Type: Task
Components
Philip Nee created KAFKA-14950:
--
Summary: Implement assign() and assignment()
Key: KAFKA-14950
URL: https://issues.apache.org/jira/browse/KAFKA-14950
Project: Kafka
Issue Type: Sub-task
Philip Nee created KAFKA-14960:
--
Summary: Metadata Request Manager and listTopics/partitionsFor API
Key: KAFKA-14960
URL: https://issues.apache.org/jira/browse/KAFKA-14960
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-13891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-13891.
Fix Version/s: 3.5.0
3.4.1
(was: 3.6.0
[
https://issues.apache.org/jira/browse/KAFKA-14016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-14016.
Fix Version/s: 3.5.0
3.4.1
Assignee: Philip Nee
Resolution
[
https://issues.apache.org/jira/browse/KAFKA-13668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-13668.
Fix Version/s: 3.6.0
Resolution: Fixed
> Failed cluster authorization should not be fa
Philip Nee created KAFKA-14977:
--
Summary: testDescribeStateOfExistingGroupWithRoundRobinAssignor is
flaky
Key: KAFKA-14977
URL: https://issues.apache.org/jira/browse/KAFKA-14977
Project: Kafka
Philip Nee created KAFKA-15173:
--
Summary: ApplicationEventQueue and BackgroundEventQueue should be
bounded
Key: KAFKA-15173
URL: https://issues.apache.org/jira/browse/KAFKA-15173
Project: Kafka
Philip Nee created KAFKA-15174:
--
Summary: Ensure the correct thread is executing the callbacks
Key: KAFKA-15174
URL: https://issues.apache.org/jira/browse/KAFKA-15174
Project: Kafka
Issue Type
Philip Nee created KAFKA-15175:
--
Summary: Assess the use of nio2 asynchronous channel for
KafkaConsumer
Key: KAFKA-15175
URL: https://issues.apache.org/jira/browse/KAFKA-15175
Project: Kafka
Philip Nee created KAFKA-17825:
--
Summary: ByteBufferDeserializaer's array size can be inconsistent
with the older version
Key: KAFKA-17825
URL: https://issues.apache.org/jira/browse/KAFKA-17825
Pr
Philip Nee created KAFKA-18139:
--
Summary: AsyncKafkaConsumer's ConsumerNetworkThread loop requires
further optimization
Key: KAFKA-18139
URL: https://issues.apache.org/jira/browse/KAFKA-18139
Pr
Philip Nee created KAFKA-18376:
--
Summary: High CPU load when AsyncKafkaConsumer uses a small max
poll value
Key: KAFKA-18376
URL: https://issues.apache.org/jira/browse/KAFKA-18376
Project: Kafka
Philip Nee created KAFKA-18194:
--
Summary: Flaky test_broker_rolling_bounce due to frequent
rebootstrapping
Key: KAFKA-18194
URL: https://issues.apache.org/jira/browse/KAFKA-18194
Project: Kafka
Philip Nee created KAFKA-18216:
--
Summary: High water mark or last stable offset aren't always
updated after a fetch request is completed
Key: KAFKA-18216
URL: https://issues.apache.org/jira/browse/KAFKA-
Philip Nee created KAFKA-18217:
--
Summary: Slow HWM/LSO update might have subtle effect on the
consumer lag reporting
Key: KAFKA-18217
URL: https://issues.apache.org/jira/browse/KAFKA-18217
Project
101 - 172 of 172 matches
Mail list logo
