[GitHub] kafka pull request #2875: KAFKA-4808 : Send of null key to a compacted topic...

2017-04-19 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/2875 KAFKA-4808 : Send of null key to a compacted topic should throw non-retriable error back to user You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] kafka pull request #2206: KAFKA-4454 : Authorizer should also include the Pr...

2016-12-02 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/2206 KAFKA-4454 : Authorizer should also include the Principal generated by the PrincipalBuilder. Added support to include the Principal generated by the PrincipalBuilder in KafkaChannel You

[GitHub] kafka pull request #2116: KAFKA-4362 : Consumer can fail after reassignment ...

2016-11-08 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/2116 KAFKA-4362 : Consumer can fail after reassignment of the offsets topic partition You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] kafka pull request #1913: KAFKA-3175 (Rebased) : topic not accessible after ...

2016-09-26 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/1913 KAFKA-3175 (Rebased) : topic not accessible after deletion even when delete.topic.enable is disabled Rebased the patch with current trunk. You can merge this pull request into a Git

[GitHub] kafka pull request: KAFKA-3720 : Deprecated BufferExhaustedExcepti...

2016-05-20 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/1417 KAFKA-3720 : Deprecated BufferExhaustedException and also removed its use and the related sensor metric BufferExhaustedException is no longer used and should be deprecated and the

[GitHub] kafka pull request: KAFKA-3722 : The PlaintextChannelBuilder shoul...

2016-05-18 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/1403 KAFKA-3722 : The PlaintextChannelBuilder should always use the DefaultPrincipalBuilder Consider this scenario : 1) We have a Kafka Broker running on PlainText and SSL port

[GitHub] kafka pull request: KAFKA-3651 : Remove the condition variable wai...

2016-05-03 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/1314 KAFKA-3651 : Remove the condition variable waiting on memory availabilty in Bufferpool when a TimeoutException is thrown Whenever the BufferPool throws a "Failed to allocate memory w

[GitHub] kafka pull request: KAFKA-3393 : Updated the docs to reflect the d...

2016-03-14 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/1060 KAFKA-3393 : Updated the docs to reflect the deprecation of block.on.buffer.full and usage of max.block.ms You can merge this pull request into a Git repository by running: $ git pull

[GitHub] kafka pull request: KAFKA-3175 : Topic not accessible after deleti...

2016-02-01 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/846 KAFKA-3175 : Topic not accessible after deletion even when delete.topic.enable is disabled Remove topics under /admin/delete_topics path in zk if deleteTopic is disabled. The topic should

[GitHub] kafka pull request: KAFKA-3147 : Memory records is not writable in...

2016-01-28 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/825 KAFKA-3147 : Memory records is not writable in MirrorMaker Remove the batch from the RecordAccumulator once its closed while aborting batches. Make sure we don't accept new batch appen

[GitHub] kafka pull request: KAFKA-2975

2016-01-06 Thread MayureshGharat
Github user MayureshGharat closed the pull request at: https://github.com/apache/kafka/pull/658 --- 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] kafka pull request: KAFKA-2937 : Disable the leaderIsr check if th...

2016-01-04 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/729 KAFKA-2937 : Disable the leaderIsr check if the topic is to be deleted. The check was implemented in KAFKA-340 : If we are shutting down a broker when the ISR of a partition includes only

[GitHub] kafka pull request: KAFKA-1860

2015-12-18 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/698 KAFKA-1860 The JVM should stop if the underlying file system goes in to Read only mode You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] kafka pull request: KAFKA-1860

2015-12-18 Thread MayureshGharat
Github user MayureshGharat closed the pull request at: https://github.com/apache/kafka/pull/697 --- 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] kafka pull request: KAFKA-1860

2015-12-18 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/697 KAFKA-1860 The JVM should stop if the underlying file system goes in to Read only mode You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] kafka pull request: KAFKA-3013

2015-12-18 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/695 KAFKA-3013 Added topic-partition information to the exception message on batch expiry in RecordAccumulator You can merge this pull request into a Git repository by running: $ git pull

[GitHub] kafka pull request: KAFKA-2975

2015-12-09 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/658 KAFKA-2975 The newtorkClient should request a metadata update after it gets an error in the handleResponse(). Currently in data pipeline, 1) Lets say Mirror Maker requestTimeout

[GitHub] kafka pull request: KAFKA-1911

2015-12-07 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/636 KAFKA-1911 Made delete topic on brokers async You can merge this pull request into a Git repository by running: $ git pull https://github.com/MayureshGharat/kafka kafka-1911

[GitHub] kafka pull request: KAFKA-2805

2015-11-11 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/503 KAFKA-2805 Removed the check for only those expiring batches whose metadata is unavailable. Now the batches will be expired irrespective of whether the leader is available or not, as soon as

[GitHub] kafka pull request: KAFKA-2120

2015-10-15 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/320 KAFKA-2120 Trivial fix to get rid of unused statements in kafkaProducer. You can merge this pull request into a Git repository by running: $ git pull https://github.com/MayureshGharat

[GitHub] kafka pull request: KAFKA-2428

2015-10-06 Thread MayureshGharat
GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/282 KAFKA-2428 Add sanity test in kafkaConsumer for the timeouts. This is a followup ticket for Kafka-2120. You can merge this pull request into a Git repository by running: $ git pull