Philip Nee created KAFKA-15250:
--
Summary: DefaultBackgroundThread is running tight loop
Key: KAFKA-15250
URL: https://issues.apache.org/jira/browse/KAFKA-15250
Project: Kafka
Issue Type: Bug
Philip Nee created KAFKA-15304:
--
Summary: CompletableApplicationEvents aren't being completed when
the consumer is closing
Key: KAFKA-15304
URL: https://issues.apache.org/jira/browse/KAFKA-15304
Project:
Philip Nee created KAFKA-15305:
--
Summary: The background thread should try to process the remaining
task until the shutdown timer is expired
Key: KAFKA-15305
URL: https://issues.apache.org/jira/browse/KAFKA-15305
Philip Nee created KAFKA-15333:
--
Summary: Flaky build failure throwing Connect Exception: Could not
connect to server
Key: KAFKA-15333
URL: https://issues.apache.org/jira/browse/KAFKA-15333
Project:
Philip Nee created KAFKA-15474:
--
Summary:
AbstractCoordinator.testWakeupAfterSyncGroupReceivedExternalCompletion seems
flaky
Key: KAFKA-15474
URL: https://issues.apache.org/jira/browse/KAFKA-15474
Proje
Philip Nee created KAFKA-15475:
--
Summary: Timeout request might retry forever even if the user API
times out in AsyncConsumer
Key: KAFKA-15475
URL: https://issues.apache.org/jira/browse/KAFKA-15475
Proje
Philip Nee created KAFKA-15531:
--
Summary: Ensure coordinator node is removed upon disconnection
exception
Key: KAFKA-15531
URL: https://issues.apache.org/jira/browse/KAFKA-15531
Project: Kafka
Philip Nee created KAFKA-15533:
--
Summary: Ensure HeartbeatRequestManager only send out some fields
once
Key: KAFKA-15533
URL: https://issues.apache.org/jira/browse/KAFKA-15533
Project: Kafka
Is
Philip Nee created KAFKA-15534:
--
Summary: Propagate client response time when timeout to the
request handler
Key: KAFKA-15534
URL: https://issues.apache.org/jira/browse/KAFKA-15534
Project: Kafka
Philip Nee created KAFKA-15548:
--
Summary: Handling close() properly
Key: KAFKA-15548
URL: https://issues.apache.org/jira/browse/KAFKA-15548
Project: Kafka
Issue Type: Bug
Components: c
Philip Nee created KAFKA-15551:
--
Summary: Evaluate conditions for short circuiting consumer API
calls
Key: KAFKA-15551
URL: https://issues.apache.org/jira/browse/KAFKA-15551
Project: Kafka
Issu
Philip Nee created KAFKA-15553:
--
Summary: Review committed offset refresh logic
Key: KAFKA-15553
URL: https://issues.apache.org/jira/browse/KAFKA-15553
Project: Kafka
Issue Type: Bug
C
Philip Nee created KAFKA-15562:
--
Summary: CommitRequestManager needs to test different error
handling
Key: KAFKA-15562
URL: https://issues.apache.org/jira/browse/KAFKA-15562
Project: Kafka
Issu
[
https://issues.apache.org/jira/browse/KAFKA-15278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-15278.
Resolution: Fixed
> Implement client support for KIP-848 ConsumerGroupHeartbeat protocol RPC
> ---
Philip Nee created KAFKA-15588:
--
Summary: Purge the unsent offset commits/fetches when the member
is fenced
Key: KAFKA-15588
URL: https://issues.apache.org/jira/browse/KAFKA-15588
Project: Kafka
Philip Nee created KAFKA-15592:
--
Summary: Member does not need to always try to join a group when a
groupId is configured
Key: KAFKA-15592
URL: https://issues.apache.org/jira/browse/KAFKA-15592
Project:
Philip Nee created KAFKA-15642:
--
Summary: Ensure offset fetcher behaves correctly when the request
is Timeout
Key: KAFKA-15642
URL: https://issues.apache.org/jira/browse/KAFKA-15642
Project: Kafka
Philip Nee created KAFKA-15697:
--
Summary: Add local assignor and ensure it cannot be used with
server side assignor
Key: KAFKA-15697
URL: https://issues.apache.org/jira/browse/KAFKA-15697
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-15550.
Resolution: Fixed
> OffsetsForTimes validation for negative timestamps in new consumer
> -
[
https://issues.apache.org/jira/browse/KAFKA-15631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-15631.
Resolution: Not A Problem
> Do not send new heartbeat request while another one in-flight
> --
Philip Nee created KAFKA-15773:
--
Summary: Group protocol configuration should be validated
Key: KAFKA-15773
URL: https://issues.apache.org/jira/browse/KAFKA-15773
Project: Kafka
Issue Type: Impr
[
https://issues.apache.org/jira/browse/KAFKA-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-15562.
Resolution: Fixed
> Ensure fetch offset and commit offset handler handles both timeout and
> vari
[
https://issues.apache.org/jira/browse/KAFKA-15316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-15316.
Resolution: Fixed
> CommitRequestManager not calling RequestState callbacks
> ---
[
https://issues.apache.org/jira/browse/KAFKA-15531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-15531.
Resolution: Fixed
> Ensure coordinator node is removed upon disconnection exception
>
[
https://issues.apache.org/jira/browse/KAFKA-15679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-15679.
Resolution: Fixed
> Client support for new consumer configs
>
Philip Nee created KAFKA-15775:
--
Summary: Implement listTopics() and partitionFor() for the
AsyncKafkaConsumer
Key: KAFKA-15775
URL: https://issues.apache.org/jira/browse/KAFKA-15775
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-15686.
Assignee: Philip Nee
Resolution: Won't Fix
The user can use the admin client to get the part
Philip Nee created KAFKA-15803:
--
Summary: Update last seen epcoh during commit
Key: KAFKA-15803
URL: https://issues.apache.org/jira/browse/KAFKA-15803
Project: Kafka
Issue Type: Task
Philip Nee created KAFKA-15818:
--
Summary: Implement max poll internval
Key: KAFKA-15818
URL: https://issues.apache.org/jira/browse/KAFKA-15818
Project: Kafka
Issue Type: Task
Component
Philip Nee created KAFKA-15836:
--
Summary: KafkaConsumer subscribe to multiple topics does not
respect max.poll.records
Key: KAFKA-15836
URL: https://issues.apache.org/jira/browse/KAFKA-15836
Project: Kaf
[
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 callbacks
> ---
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: Bu
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: K
[
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 respect max.p
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: Imp
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
C
[
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.
> AsyncKafkaConsume
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
Project
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: K
[
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 in a
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 coordinator discovery
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
Pr
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
Co
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/browse/KA
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
Project:
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
Proj
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: I
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 AsyncKafkaConsumer
[
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 running tigh
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: Imp
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: Imp
[
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-16115
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: K
[
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 metrics
> --
[
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 metrics
> --
[
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 metrics
> --
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 Type
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: Kaf
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-16433
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 consumer
> ---
[
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 Consumer
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 Ty
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
Component
[
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 skeleton
> -
>
>
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 package
> --
[
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 package
> -
>
>
[
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 package
> -
[
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 package
> -
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: consume
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 T
[
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)
Resolution
[
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: Fixe
[
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 fatal f
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
Is
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
Project:
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
Project: Ka
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
1 - 100 of 102 matches
Mail list logo