GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/4204
KAFKA-5238: BrokerTopicMetrics can be recreated after topic is deleted
Avoiding a DelayedFetch recreate the metrics when a topic has been
deleted
developed with @mimaison
Github user edoardocomar closed the pull request at:
https://github.com/apache/kafka/pull/1934
---
Github user edoardocomar closed the pull request at:
https://github.com/apache/kafka/pull/1535
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user edoardocomar closed the pull request at:
https://github.com/apache/kafka/pull/1545
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/3035
DOC: clarifications on message committed to the log
based on conversations with @vahidhashemian @rajinisivaram @apurvam
The docs didn't make clear that what gets committed and what
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/3004
KAFKA-4982: add protocol and listener tags to socket-server-metrics
Added tags
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/edoardocomar
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/2936
MINOR: JoinGroupRequest V0 invalid rebalance timeout
A JoinGroupRequest V0 built with the Builder had
a rebalance timeout = -1 rather than equal to session timeout
as it would have
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/2847
MINOR: update num.x.threads server.properties comments
num.io.threads was described as doing disk-IO
the description in KafkaConfig is more accurate
You can merge this pull request
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/2768
KAFKA-4981 Add connection-accept-rate and connection-prepare-rate
KAFKA-4981 Add connection-accept-rate and connection-prepare-rate metrics
added metrics per network processor
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/2694
MINOR: FetchRequest.Builder maxBytes for version <3
The maxBytes field should be set to DEFAULT_RESPONSE_MAX_BYTES,
the same way as the constructor using the Struct d
Github user edoardocomar closed the pull request at:
https://github.com/apache/kafka/pull/1089
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user edoardocomar closed the pull request at:
https://github.com/apache/kafka/pull/2351
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/2351
MINOR: add Eclipse generated files to toplevel .gitignore
Ignoring sibfolders' .gitignore except tests
Ignoring core/cache-main and core/cache-tests
You can merge this pull request
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/2325
KAFKA-4441 Monitoring incorrect during topic creation and deletion
OfflinePartitionsCount PreferredReplicaImbalanceCount metrics check for
topic being deleted
Added integration
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/2293
KAFKA-4180 : Authentication with multiple actives Kafka
producers/consumers
Changed caching in LoginManager to allow one LoginManager per client
JAAS configuration.
Added test
Github user edoardocomar closed the pull request at:
https://github.com/apache/kafka/pull/1989
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/1989
Kafka 4180 - Shared authentification with multiple actives Kafka
producers/consumers
This PR builds on top of @rajinisivaram
https://github.com/apache/kafka/pull/1979
codeveloped
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/1908
Kafka 3396
Reopening of https://github.com/apache/kafka/pull/1428
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/edoardocomar/kafka KAFKA
Github user edoardocomar closed the pull request at:
https://github.com/apache/kafka/pull/1428
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/1545
KAFKA-3727 - ClientListener for UnknownTopicOrPartitionException
Added a ClientListener to KafkaConsumer, Fetcher and Client
Modified Fetcher and NetworkClient to notify listeners
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/1535
KAFKA-3727 - ConsumerListener for UnknownTopicOrPartitionException
Added a ConsumerListener to KafkaConsumer
Modified Fetcher and Cluster to account for Unknown Topics
Added
Github user edoardocomar closed the pull request at:
https://github.com/apache/kafka/pull/1350
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/1428
KAFKA-3396 : Unauthorized topics are returned to the user
Modified KafkaApis to return Errors.UNKNOWN_TOPIC_OR_PARTITION if
principal has no Describe access to topic
Unit tests
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/1425
KAFKA-3728 EndToEndAuthorizationTest offsets_topic misconfigured
Set OffsetsTopicReplicationFactorProp to 3 like MinInSyncReplicasProp
Earlier set acl for admin to read all
Github user edoardocomar closed the pull request at:
https://github.com/apache/kafka/pull/1414
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user edoardocomar closed the pull request at:
https://github.com/apache/kafka/pull/1414
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user edoardocomar reopened a pull request:
https://github.com/apache/kafka/pull/1414
KAFKA-3728 EndToEndAuthorizationTest offsets_topic misconfigured
Set OffsetsTopicReplicationFactorProp to 3 like MinInSyncReplicasProp
and OffsetCommitRequiredAcksProp to 1 to avoid
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/1414
KAFKA-3728 EndToEndAuthorizationTest offsets_topic misconfigured
Set OffsetsTopicReplicationFactorProp to 3 like MinInSyncReplicasProp
and OffsetCommitRequiredAcksProp to 1 to avoid
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/1352
KAFKA-3682 ArrayIndexOutOfBoundsException thrown by
SkimpyOffsetMap.get() when full
Limited number of attempts to number of map slots after the internal
positionOf() goes
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/1350
KAFKA-3679 Allow reuse of implementation of RFC 4616 in PlainSaslServer
extracted authorize(username,password) from evaluateResponse(bytes)
You can merge this pull request into a Git
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/1082
KAFKA-2832: Add a consumer config option to exclude internal topics
A new consumer config option 'exclude.internal.topics' was added to
allow excluding internal topics when wildcards
GitHub user edoardocomar opened a pull request:
https://github.com/apache/kafka/pull/1089
KAFKA-3415: Add partitions check if 0 partitions are to be added
If no partitions are to be added, the command will exit gracefully with
retcode 0 and a printed message.
This patch
32 matches
Mail list logo
