[jira] [Assigned] (KAFKA-14648) Do not fail clients if bootstrap servers is not immediately resolvable
[ https://issues.apache.org/jira/browse/KAFKA-14648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brenden DeLuna reassigned KAFKA-14648: -- Assignee: Brenden DeLuna > Do not fail clients if bootstrap servers is not immediately resolvable > -- > > Key: KAFKA-14648 > URL: https://issues.apache.org/jira/browse/KAFKA-14648 > Project: Kafka > Issue Type: Bug >Reporter: Jason Gustafson >Assignee: Brenden DeLuna >Priority: Major > > In dynamic environments, such as system tests, there is sometimes a delay > between when a client is initialized and when the configured bootstrap > servers become available in DNS. Currently clients will fail immediately if > none of the bootstrap servers can resolve. It would be more convenient for > these environments to provide a grace period to give more time for > initialization. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-14648) Do not fail clients if bootstrap servers is not immediately resolvable
[ https://issues.apache.org/jira/browse/KAFKA-14648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brenden DeLuna reassigned KAFKA-14648: -- Assignee: (was: Brenden DeLuna) > Do not fail clients if bootstrap servers is not immediately resolvable > -- > > Key: KAFKA-14648 > URL: https://issues.apache.org/jira/browse/KAFKA-14648 > Project: Kafka > Issue Type: Bug >Reporter: Jason Gustafson >Priority: Major > > In dynamic environments, such as system tests, there is sometimes a delay > between when a client is initialized and when the configured bootstrap > servers become available in DNS. Currently clients will fail immediately if > none of the bootstrap servers can resolve. It would be more convenient for > these environments to provide a grace period to give more time for > initialization. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Resolved] (KAFKA-16000) Migrate MembershipManagerImplTest away from ConsumerTestBuilder
[ https://issues.apache.org/jira/browse/KAFKA-16000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brenden DeLuna resolved KAFKA-16000. Resolution: Fixed [https://github.com/apache/kafka/pull/16312] merged > Migrate MembershipManagerImplTest away from ConsumerTestBuilder > --- > > Key: KAFKA-16000 > URL: https://issues.apache.org/jira/browse/KAFKA-16000 > Project: Kafka > Issue Type: Test > Components: clients, consumer, unit tests >Reporter: Lucas Brutschy >Assignee: Brenden DeLuna >Priority: Minor > Labels: consumer-threading-refactor, unit-tests > Fix For: 3.9.0 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (KAFKA-16912) Migrate ConsumerNetworkThreadTest.testPollResultTimer() to NetworkClientDelegateTest
[ https://issues.apache.org/jira/browse/KAFKA-16912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brenden DeLuna updated KAFKA-16912: --- Labels: migration unit-test (was: ) > Migrate ConsumerNetworkThreadTest.testPollResultTimer() to > NetworkClientDelegateTest > > > Key: KAFKA-16912 > URL: https://issues.apache.org/jira/browse/KAFKA-16912 > Project: Kafka > Issue Type: Test > Components: clients, consumer, unit tests >Reporter: Brenden DeLuna >Assignee: Brenden DeLuna >Priority: Minor > Labels: migration, unit-test > > ConsumerNetworkThreadTest.testPollResultTimer() only tests > NetworkClientDelegate, it does not test ConsumerNetworkThread. This test > should be moved to NetworkClientDelegateTest. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-16912) Migrate ConsumerNetworkThreadTest.testPollResultTimer() to NetworkClientDelegateTest
[ https://issues.apache.org/jira/browse/KAFKA-16912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brenden DeLuna reassigned KAFKA-16912: -- Assignee: Brenden DeLuna > Migrate ConsumerNetworkThreadTest.testPollResultTimer() to > NetworkClientDelegateTest > > > Key: KAFKA-16912 > URL: https://issues.apache.org/jira/browse/KAFKA-16912 > Project: Kafka > Issue Type: Test > Components: clients, consumer, unit tests >Reporter: Brenden DeLuna >Assignee: Brenden DeLuna >Priority: Minor > > ConsumerNetworkThreadTest.testPollResultTimer() only tests > NetworkClientDelegate, it does not test ConsumerNetworkThread. This test > should be moved to NetworkClientDelegateTest. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16912) Migrate ConsumerNetworkThreadTest.testPollResultTimer() to NetworkClientDelegateTest
Brenden DeLuna created KAFKA-16912: -- Summary: Migrate ConsumerNetworkThreadTest.testPollResultTimer() to NetworkClientDelegateTest Key: KAFKA-16912 URL: https://issues.apache.org/jira/browse/KAFKA-16912 Project: Kafka Issue Type: Test Components: clients, consumer, unit tests Reporter: Brenden DeLuna ConsumerNetworkThreadTest.testPollResultTimer() only tests NetworkClientDelegate, it does not test ConsumerNetworkThread. This test should be moved to NetworkClientDelegateTest. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-7300) Add KafkaConsumer fetch-error-rate and fetch-error-total metrics
[ https://issues.apache.org/jira/browse/KAFKA-7300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brenden DeLuna reassigned KAFKA-7300: - Assignee: Brenden DeLuna (was: Philip Nee) > Add KafkaConsumer fetch-error-rate and fetch-error-total metrics > - > > Key: KAFKA-7300 > URL: https://issues.apache.org/jira/browse/KAFKA-7300 > Project: Kafka > Issue Type: New Feature > Components: clients, consumer, metrics >Reporter: Kevin Lu >Assignee: Brenden DeLuna >Priority: Minor > > [https://cwiki.apache.org/confluence/display/KAFKA/KIP-356%3A+Add+KafkaConsumer+fetch-error-rate+and+fetch-error-total+metrics] > > The KafkaConsumer is a complex client that requires many different components > to function properly. When a consumer is not operating properly, it can be > difficult to identify the root cause and which component is causing issues > (ConsumerCoordinator, Fetcher, ConsumerNetworkClient, etc). > > This aims to improve the monitoring and detection of KafkaConsumer’s Fetcher > component. > > Fetcher will send a fetch request for each node that the consumer has > assigned partitions for. > > This fetch request may fail under the following cases: > * Intermittent network issues (goes to onFailure) > * Node sent an invalid full/incremental fetch response > (FetchSessionHandler’s handleResponse returns false) > * FetchSessionIdNotFound > * InvalidFetchSessionEpochException > > These cases are logged, but it would be valuable to provide a corresponding > metric that allows for monitoring and alerting. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-16558) Implement HeartbeatRequestState.toStringBase()
[
https://issues.apache.org/jira/browse/KAFKA-16558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Brenden DeLuna reassigned KAFKA-16558:
--
Assignee: Brenden DeLuna (was: Kirk True)
> Implement HeartbeatRequestState.toStringBase()
> --
>
> Key: KAFKA-16558
> URL: https://issues.apache.org/jira/browse/KAFKA-16558
> Project: Kafka
> Issue Type: Bug
> Components: clients, consumer
>Affects Versions: 3.7.0
>Reporter: Kirk True
>Assignee: Brenden DeLuna
>Priority: Minor
> Labels: consumer-threading-refactor, logging
> Fix For: 3.8.0
>
>
> The inner class {{HeartbeatRequestState}} does not override the
> {{toStringBase()}} method. This affects debugging and troubleshooting
> consumer issues.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Assigned] (KAFKA-16557) Fix OffsetFetchRequestState.toString()
[
https://issues.apache.org/jira/browse/KAFKA-16557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Brenden DeLuna reassigned KAFKA-16557:
--
Assignee: Brenden DeLuna (was: Kirk True)
> Fix OffsetFetchRequestState.toString()
> --
>
> Key: KAFKA-16557
> URL: https://issues.apache.org/jira/browse/KAFKA-16557
> Project: Kafka
> Issue Type: Bug
> Components: clients, consumer
>Affects Versions: 3.7.0
>Reporter: Kirk True
>Assignee: Brenden DeLuna
>Priority: Minor
> Labels: consumer-threading-refactor, logging
> Fix For: 3.8.0
>
>
> The code incorrectly overrides the {{toString()}} method instead of
> overriding {{{}toStringBase(){}}}. This affects debugging and troubleshooting
> consumer issues.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Assigned] (KAFKA-16000) Migrate MembershipManagerImplTest away from ConsumerTestBuilder
[ https://issues.apache.org/jira/browse/KAFKA-16000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brenden DeLuna reassigned KAFKA-16000: -- Assignee: Brenden DeLuna (was: Kirk True) > Migrate MembershipManagerImplTest away from ConsumerTestBuilder > --- > > Key: KAFKA-16000 > URL: https://issues.apache.org/jira/browse/KAFKA-16000 > Project: Kafka > Issue Type: Test > Components: clients, consumer, unit tests >Reporter: Lucas Brutschy >Assignee: Brenden DeLuna >Priority: Minor > Labels: consumer-threading-refactor, unit-tests > Fix For: 3.8.0 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-15999) Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder
[ https://issues.apache.org/jira/browse/KAFKA-15999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brenden DeLuna reassigned KAFKA-15999: -- Assignee: Brenden DeLuna (was: Kirk True) > Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder > - > > Key: KAFKA-15999 > URL: https://issues.apache.org/jira/browse/KAFKA-15999 > Project: Kafka > Issue Type: Test > Components: clients, consumer, unit tests >Reporter: Lucas Brutschy >Assignee: Brenden DeLuna >Priority: Minor > Labels: consumer-threading-refactor, unit-tests > Fix For: 3.8.0 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-16001) Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilder
[ https://issues.apache.org/jira/browse/KAFKA-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brenden DeLuna reassigned KAFKA-16001: -- Assignee: Brenden DeLuna > Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilder > --- > > Key: KAFKA-16001 > URL: https://issues.apache.org/jira/browse/KAFKA-16001 > Project: Kafka > Issue Type: Test > Components: clients, consumer, unit tests >Reporter: Lucas Brutschy >Assignee: Brenden DeLuna >Priority: Minor > Labels: consumer-threading-refactor, unit-tests > Fix For: 3.8.0 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
