kafka git commit: MINOR: Fix KafkaConsumer.commitSync() javadoc @throws declarations

Repository: kafka Updated Branches: refs/heads/0.11.0 1c9581e2e -> 1df108421 MINOR: Fix KafkaConsumer.commitSync() javadoc @throws declarations Throws IllegalArgumentException is the offset is negative Author: Mickael Maison Reviewers: Ismael Juma

kafka git commit: MINOR: Only include transactional id in LogContext if it's set

Repository: kafka Updated Branches: refs/heads/trunk 92c06cbad -> 80e0af50d MINOR: Only include transactional id in LogContext if it's set Author: Ismael Juma Reviewers: Apurva Mehta , Jason Gustafson Closes #3910 from

kafka git commit: KAFKA-5913; Add hasOffset() and hasTimestamp() methods to RecordMetadata

Repository: kafka Updated Branches: refs/heads/trunk 690575ec4 -> ea533f0c5 KAFKA-5913; Add hasOffset() and hasTimestamp() methods to RecordMetadata These methods help users check for cases in which this metadata was not returned by the broker (e.g. in the case of acks=0 or a duplicate error

kafka git commit: MINOR: Follow-up improvements on top of KAFKA-5793

Repository: kafka Updated Branches: refs/heads/trunk c8c6ab632 -> 690575ec4 MINOR: Follow-up improvements on top of KAFKA-5793 Simplified the condition in Sender#failBatch() Added log in TransactionManager#updateLastAckedOffset() Author: tedyu Reviewers: Jason

kafka git commit: KAFKA-5959; Fix NPE in Sender.canRetry when idempotence is not enabled

Repository: kafka Updated Branches: refs/heads/trunk d60f011d7 -> 8f90fd653 KAFKA-5959; Fix NPE in Sender.canRetry when idempotence is not enabled Author: Apurva Mehta Reviewers: tedyu , Jason Gustafson Closes #3947 from

kafka git commit: KAFKA-5358; Consumer perf tool should count rebalance time (KIP-177)

Repository: kafka Updated Branches: refs/heads/trunk c82be0f30 -> 239dad1b9 KAFKA-5358; Consumer perf tool should count rebalance time (KIP-177) Author: huxihx Reviewers: Jason Gustafson Closes #3188 from huxihx/KAKFA-5358 Project:

kafka git commit: KAFKA-5793; Tighten up the semantics of the OutOfOrderSequenceException

Repository: kafka Updated Branches: refs/heads/trunk 69d2a1771 -> 94692288b KAFKA-5793; Tighten up the semantics of the OutOfOrderSequenceException Description of the solution can be found here:

kafka git commit: MINOR: Remove unused SecurityProtocol.TRACE

Repository: kafka Updated Branches: refs/heads/trunk 2656659e0 -> dfd625daa MINOR: Remove unused SecurityProtocol.TRACE It adds complexity for no benefit since we don't use it anywhere. Also removed a few unused imports, variables and default parameters. Author: Ismael Juma

kafka git commit: MINOR: Fix typo in test log4j.properties

Repository: kafka Updated Branches: refs/heads/trunk 9d2437a46 -> f47996ccb MINOR: Fix typo in test log4j.properties Author: Jeff Widman Reviewers: Jason Gustafson Closes #3851 from jeffwidman/patch-1 Project:

kafka git commit: MINOR: Protocol schema refactor follow-up

Repository: kafka Updated Branches: refs/heads/trunk 5e0bb3df9 -> 92c06cbad MINOR: Protocol schema refactor follow-up - Use constants in a few places that were missed - Remove ProtoUtils by moving its methods to Schema - Merge SchemaVisitor and SchemaVisitorAdapter - Change SchemaVisitor

kafka git commit: KAFKA-6003; Accept appends on replicas unconditionally when local producer state doesn't exist

Repository: kafka Updated Branches: refs/heads/trunk b5b266eee -> 6ea4fffdd KAFKA-6003; Accept appends on replicas unconditionally when local producer state doesn't exist Without this patch, if the replica's log was somehow truncated before the leader's, it is possible for the replica

kafka git commit: KAFKA-5547; Return TOPIC_AUTHORIZATION_FAILED error if no describe access for topics

Repository: kafka Updated Branches: refs/heads/trunk fb6ca658d -> 10cd98cc8 KAFKA-5547; Return TOPIC_AUTHORIZATION_FAILED error if no describe access for topics Author: Manikumar Reddy Reviewers: Rajini Sivaram , Ismael Juma

kafka git commit: KAFKA-5547; Return TOPIC_AUTHORIZATION_FAILED error if no describe access for topics

Repository: kafka Updated Branches: refs/heads/1.0 32ee1a879 -> ebeee3c8d KAFKA-5547; Return TOPIC_AUTHORIZATION_FAILED error if no describe access for topics Author: Manikumar Reddy Reviewers: Rajini Sivaram , Ismael Juma

kafka git commit: KAFKA-6015; Fix NPE in RecordAccumulator after ProducerId reset

Repository: kafka Updated Branches: refs/heads/trunk 10cd98cc8 -> 105ab47ed KAFKA-6015; Fix NPE in RecordAccumulator after ProducerId reset It is possible for batches with sequence numbers to be in the `deque` while at the same time the in flight batches in the `TransactionManager` are

kafka git commit: KAFKA-6015; Fix NPE in RecordAccumulator after ProducerId reset

Repository: kafka Updated Branches: refs/heads/1.0 ebeee3c8d -> aa1e4c235 KAFKA-6015; Fix NPE in RecordAccumulator after ProducerId reset It is possible for batches with sequence numbers to be in the `deque` while at the same time the in flight batches in the `TransactionManager` are removed

kafka git commit: KAFKA-5829; Only delete producer snapshots before the recovery point

Repository: kafka Updated Branches: refs/heads/trunk 2427a4476 -> 91517e8fb KAFKA-5829; Only delete producer snapshots before the recovery point Author: Ismael Juma Reviewers: Jason Gustafson Closes #4023 from

kafka git commit: KAFKA-5829; Only delete producer snapshots before the recovery point

Repository: kafka Updated Branches: refs/heads/1.0 963733cd0 -> d3a603cb9 KAFKA-5829; Only delete producer snapshots before the recovery point Author: Ismael Juma Reviewers: Jason Gustafson Closes #4023 from

kafka git commit: KAFKA-5495; Update docs to use `kafka-consumer-groups.sh` for checking consumer offsets

Repository: kafka Updated Branches: refs/heads/trunk 39d5cdccc -> cdbf806e2 KAFKA-5495; Update docs to use `kafka-consumer-groups.sh` for checking consumer offsets And remove the deprecated `ConsumerOffsetChecker` example. Author: Vahid Hashemian Reviewers:

[1/2] kafka git commit: MINOR: Use SecurityProtocol in AuthenticationContext

Repository: kafka Updated Branches: refs/heads/trunk 198302fee -> 5383f9bed http://git-wip-us.apache.org/repos/asf/kafka/blob/5383f9be/core/src/test/scala/integration/kafka/api/SslEndToEndAuthorizationTest.scala -- diff --git

[2/2] kafka git commit: MINOR: Use SecurityProtocol in AuthenticationContext

MINOR: Use SecurityProtocol in AuthenticationContext Since we removed the unused `TRACE` option from `SecurityProtocol`, it now seems safer to expose it from `AuthenticationContext`. Additionally this patch exposes javadocs under security.auth and relocates the `Login` and

kafka git commit: KAFKA-6016; Make the reassign partitions system test use the idempotent producer

Repository: kafka Updated Branches: refs/heads/trunk 64930cd71 -> 90b5ce3f0 KAFKA-6016; Make the reassign partitions system test use the idempotent producer With these changes, we are ensuring that the partitions being reassigned are from non-zero offsets. We also ensure that every message

kafka git commit: KAFKA-6016; Make the reassign partitions system test use the idempotent producer

Repository: kafka Updated Branches: refs/heads/1.0 1db2fc4fd -> 8a175b0ee KAFKA-6016; Make the reassign partitions system test use the idempotent producer With these changes, we are ensuring that the partitions being reassigned are from non-zero offsets. We also ensure that every message in

kafka git commit: MINOR: Factor out some common group/transactional fields in request objects

Repository: kafka Updated Branches: refs/heads/1.0 8a175b0ee -> e409f847f MINOR: Factor out some common group/transactional fields in request objects Author: Jason Gustafson Reviewers: tedyu , Ismael Juma Closes #4047 from

kafka git commit: MINOR: Avoid some unnecessary collection copies in KafkaApis

Repository: kafka Updated Branches: refs/heads/trunk 90b5ce3f0 -> 1027ff3c7 MINOR: Avoid some unnecessary collection copies in KafkaApis Author: Jason Gustafson Reviewers: Manikumar Reddy , Ismael Juma Closes #4035 from

kafka git commit: MINOR: Avoid some unnecessary collection copies in KafkaApis

Repository: kafka Updated Branches: refs/heads/1.0 e409f847f -> e671c1cd3 MINOR: Avoid some unnecessary collection copies in KafkaApis Author: Jason Gustafson Reviewers: Manikumar Reddy , Ismael Juma Closes #4035 from

kafka git commit: MINOR: Include isolationLevel in toString of FetchRequest

Repository: kafka Updated Branches: refs/heads/trunk f5341c9f3 -> c2d9a2f30 MINOR: Include isolationLevel in toString of FetchRequest Author: Jacek Laskowski Reviewers: Apurva Mehta , Jason Gustafson Closes #4038 from

kafka git commit: MINOR: Include isolationLevel in toString of FetchRequest

Repository: kafka Updated Branches: refs/heads/1.0 937cd5206 -> a2a1226b6 MINOR: Include isolationLevel in toString of FetchRequest Author: Jacek Laskowski Reviewers: Apurva Mehta , Jason Gustafson Closes #4038 from

kafka git commit: MINOR: A few javadoc fixes

Repository: kafka Updated Branches: refs/heads/1.0 bdf05529f -> 983cc479d MINOR: A few javadoc fixes Author: Jason Gustafson Reviewers: Guozhang Wang Closes #4076 from hachikuji/javadoc-fixes (cherry picked from commit

kafka git commit: MINOR: A few javadoc fixes

Repository: kafka Updated Branches: refs/heads/trunk 7a1466392 -> f931febc8 MINOR: A few javadoc fixes Author: Jason Gustafson Reviewers: Guozhang Wang Closes #4076 from hachikuji/javadoc-fixes Project:

kafka-site git commit: Jason and Becket are PMC members

Repository: kafka-site Updated Branches: refs/heads/asf-site f18b90462 -> 52b928144 Jason and Becket are PMC members Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/52b92814 Tree:

kafka git commit: KAFKA-4860; Allow spaces in paths on windows

Repository: kafka Updated Branches: refs/heads/trunk 752e53174 -> 81e789ae3 KAFKA-4860; Allow spaces in paths on windows When we install kafka on path with spaces, batch files were failing, this PR is trying to fix this issue. Author: Vladimír Kleštinec Reviewers:

kafka git commit: KAFKA-5726; KafkaConsumer.subscribe() overload that takes just Pattern

Repository: kafka Updated Branches: refs/heads/trunk 510257646 -> 23d01c805 KAFKA-5726; KafkaConsumer.subscribe() overload that takes just Pattern - changed the interface & implementations - updated tests to use the new method where applicable Author: Attila Kreiner

kafka git commit: KAFKA-5756; Connect WorkerSourceTask synchronization issue on flush

Repository: kafka Updated Branches: refs/heads/trunk 45394d52c -> 510257646 KAFKA-5756; Connect WorkerSourceTask synchronization issue on flush Author: oleg Reviewers: Randall Hauch , Jason Gustafson Closes #3702 from

kafka git commit: KAFKA-5756; Connect WorkerSourceTask synchronization issue on flush

Repository: kafka Updated Branches: refs/heads/0.11.0 fc3eeb004 -> d93bd1aff KAFKA-5756; Connect WorkerSourceTask synchronization issue on flush Author: oleg Reviewers: Randall Hauch , Jason Gustafson Closes #3702 from

kafka git commit: KAFKA-5888; System test to check ordering of messages with transactions and max.in.flight > 1

Repository: kafka Updated Branches: refs/heads/trunk 89ba0c152 -> dd6347a5d KAFKA-5888; System test to check ordering of messages with transactions and max.in.flight > 1 To check ordering, we augment the existing transactions test to read and write from topics with one partition. Since we

kafka git commit: KAFKA-6005; Reject JoinGroup request from first member with empty protocol type/protocol list

Repository: kafka Updated Branches: refs/heads/trunk 3dcbbf703 -> 42b356500 KAFKA-6005; Reject JoinGroup request from first member with empty protocol type/protocol list Author: Manikumar Reddy Reviewers: Jason Gustafson Closes #3957 from

kafka git commit: KAFKA-4108; Improve DumpLogSegments offsets-decoder output format

Repository: kafka Updated Branches: refs/heads/trunk 9e35a2aa7 -> 5663f51ed KAFKA-4108; Improve DumpLogSegments offsets-decoder output format This PR improves the output format of DumpLogSegments when the `--offset-decoder` option is used for consuming `__consumer_offsets`, especially when

kafka git commit: KAFKA-5644; Fix Reset Consumer Group Offset tool to handle minute component of TimeZone

Repository: kafka Updated Branches: refs/heads/0.11.0 e47f2d3c4 -> d77c057dd KAFKA-5644; Fix Reset Consumer Group Offset tool to handle minute component of TimeZone Author: Manikumar Reddy Reviewers: Jason Gustafson Closes #3626 from

kafka git commit: KAFKA-5644; Fix Reset Consumer Group Offset tool to handle minute component of TimeZone

Repository: kafka Updated Branches: refs/heads/trunk 99eebc840 -> 5b99a288c KAFKA-5644; Fix Reset Consumer Group Offset tool to handle minute component of TimeZone Author: Manikumar Reddy Reviewers: Jason Gustafson Closes #3626 from

kafka git commit: KAFKA-5342; Clarify producer fatal/abortable errors and fix inconsistencies

Repository: kafka Updated Branches: refs/heads/trunk 21fea170d -> 71417552c KAFKA-5342; Clarify producer fatal/abortable errors and fix inconsistencies This patch improves documentation on the handling of errors for the idempotent/transactional producer. It also fixes a couple minor

kafka git commit: KAFKA-5342; Clarify producer fatal/abortable errors and fix inconsistencies

Repository: kafka Updated Branches: refs/heads/0.11.0 b872abf69 -> 6e5f8850d KAFKA-5342; Clarify producer fatal/abortable errors and fix inconsistencies This patch improves documentation on the handling of errors for the idempotent/transactional producer. It also fixes a couple minor

[2/3] kafka git commit: MINOR: Consolidate broker request/response handling

http://git-wip-us.apache.org/repos/asf/kafka/blob/c4d629a0/core/src/main/scala/kafka/network/RequestChannel.scala -- diff --git a/core/src/main/scala/kafka/network/RequestChannel.scala

[1/3] kafka git commit: MINOR: Consolidate broker request/response handling

Repository: kafka Updated Branches: refs/heads/trunk 05e3850b2 -> c4d629a0b http://git-wip-us.apache.org/repos/asf/kafka/blob/c4d629a0/core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala -- diff --git

[3/3] kafka git commit: MINOR: Consolidate broker request/response handling

MINOR: Consolidate broker request/response handling This patch contains a few small improvements to make request/response handling more consistent. Primarily it consolidates request/response serialization logic so that `SaslServerAuthenticator` and `KafkaApis` follow the same path. It also

kafka git commit: KAFKA-5755; KafkaProducer should be refactored to use LogContext

Repository: kafka Updated Branches: refs/heads/trunk c4d629a0b -> 607c3c21f KAFKA-5755; KafkaProducer should be refactored to use LogContext With LogContext, each producer log item is automatically prefixed with client id and transactional id. Author: huxihx

kafka git commit: KAFKA-5747; Producer snapshot loading should cover schema errors

Repository: kafka Updated Branches: refs/heads/0.11.0 fbd41d64d -> b4f3345b5 KAFKA-5747; Producer snapshot loading should cover schema errors Author: Jason Gustafson Reviewers: Apurva Mehta , Ismael Juma Closes #3688 from

kafka git commit: KAFKA-5747; Producer snapshot loading should cover schema errors

Repository: kafka Updated Branches: refs/heads/trunk 8a5a84dc6 -> bf3bfd674 KAFKA-5747; Producer snapshot loading should cover schema errors Author: Jason Gustafson Reviewers: Apurva Mehta , Ismael Juma Closes #3688 from

[2/2] kafka git commit: MINOR: Ensure consumer logging has clientId/groupId context

MINOR: Ensure consumer logging has clientId/groupId context This patch ensures that the consumer groupId and clientId are available in all log messages which makes debugging much easier when a single application has multiple consumer instances. To make this easier, I've added a new `LogContext`

[1/2] kafka git commit: MINOR: Ensure consumer logging has clientId/groupId context

Repository: kafka Updated Branches: refs/heads/trunk ed96523a2 -> 6896f1ddb http://git-wip-us.apache.org/repos/asf/kafka/blob/6896f1dd/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java

kafka git commit: KAFKA-5768; Upgrade to ducktape 0.7.1

Repository: kafka Updated Branches: refs/heads/trunk 9ef2b3ce8 -> 949577ca7 KAFKA-5768; Upgrade to ducktape 0.7.1 Author: Colin P. Mccabe Reviewers: Jason Gustafson Closes #3721 from cmccabe/KAFKA-5768 Project:

kafka git commit: KAFKA-5806; Fix transient unit test failure in trogdor coordinator shutdown

Repository: kafka Updated Branches: refs/heads/trunk 47c275349 -> ded874117 KAFKA-5806; Fix transient unit test failure in trogdor coordinator shutdown In the coordinator, we should check that 'shutdown' is not true before going to sleep waiting for the condition. Author: Colin P. Mccabe

kafka git commit: MINOR: Factor out some common group/transactional fields in request objects

Repository: kafka Updated Branches: refs/heads/trunk 6d6080f13 -> f4ac68a40 MINOR: Factor out some common group/transactional fields in request objects Author: Jason Gustafson Reviewers: tedyu , Ismael Juma Closes #4047 from

kafka git commit: KAFKA-6030; Fix Integer overflow in cleanable ratio computation

Repository: kafka Updated Branches: refs/heads/0.11.0 3c96f9128 -> bb27215ce KAFKA-6030; Fix Integer overflow in cleanable ratio computation Author: Xin Li Reviewers: Ismael Juma , Jason Gustafson Closes #4043 from lisa2lisa/fix

kafka git commit: KAFKA-6030; Fix Integer overflow in cleanable ratio computation

Repository: kafka Updated Branches: refs/heads/trunk f4ac68a40 -> 1f6494202 KAFKA-6030; Fix Integer overflow in cleanable ratio computation Author: Xin Li Reviewers: Ismael Juma , Jason Gustafson Closes #4043 from lisa2lisa/fix

kafka git commit: KAFKA-6030; Fix Integer overflow in cleanable ratio computation

Repository: kafka Updated Branches: refs/heads/1.0 529873146 -> ae4f647dd KAFKA-6030; Fix Integer overflow in cleanable ratio computation Author: Xin Li Reviewers: Ismael Juma , Jason Gustafson Closes #4043 from lisa2lisa/fix

kafka git commit: KAFKA-6026; Fix for indefinite wait in KafkaFutureImpl

Repository: kafka Updated Branches: refs/heads/trunk 1f6494202 -> b411f57c1 KAFKA-6026; Fix for indefinite wait in KafkaFutureImpl Author: bartdevylder Author: Bart De Vylder Reviewers: Colin P. Mccabe , Ismael Juma

kafka git commit: KAFKA-5970; Use ReentrantLock for delayed operation lock to avoid blocking

Repository: kafka Updated Branches: refs/heads/trunk d985513b2 -> f8621b417 KAFKA-5970; Use ReentrantLock for delayed operation lock to avoid blocking Author: Rajini Sivaram Reviewers: Guozhang Wang , Ismael Juma , Jason

kafka git commit: KAFKA-5970; Use ReentrantLock for delayed operation lock to avoid blocking

Repository: kafka Updated Branches: refs/heads/0.11.0 51ea8e76b -> ab554caee KAFKA-5970; Use ReentrantLock for delayed operation lock to avoid blocking Author: Rajini Sivaram Reviewers: Guozhang Wang , Ismael Juma , Jason

kafka git commit: MINOR: Bump the request timeout for the transactional message copier

Repository: kafka Updated Branches: refs/heads/trunk 31fe1f98e -> 34188b4cc MINOR: Bump the request timeout for the transactional message copier Multiple inflights means that when there are rolling bounces or other cluster instability, there is an increased likelihood of having previously

kafka git commit: MINOR: Bump the request timeout for the transactional message copier

Repository: kafka Updated Branches: refs/heads/1.0 43dda72f6 -> 6031ee7ad MINOR: Bump the request timeout for the transactional message copier Multiple inflights means that when there are rolling bounces or other cluster instability, there is an increased likelihood of having previously

kafka git commit: KAFKA-6042: Avoid deadlock between two groups with delayed operations

Repository: kafka Updated Branches: refs/heads/0.11.0 4e532c485 -> 4701d4cc7 KAFKA-6042: Avoid deadlock between two groups with delayed operations Author: Rajini Sivaram Reviewers: Jason Gustafson , Guozhang Wang

kafka git commit: MINOR: Update docs with regards to max.in.flight and idempotent producer

Repository: kafka Updated Branches: refs/heads/trunk 60c36b098 -> 561dd3864 MINOR: Update docs with regards to max.in.flight and idempotent producer The idempotent producer doesn't change that setting any more and the accepted range has changed. Author: Ismael Juma

kafka git commit: MINOR: Fix version in tests/kafkatest/__init__.py

Repository: kafka Updated Branches: refs/heads/1.0 53c9dd342 -> e784b3f63 MINOR: Fix version in tests/kafkatest/__init__.py Author: Colin P. Mccabe Reviewers: Jason Gustafson Closes #4267 from cmccabe/fix_version Project:

kafka-site git commit: Sync KAFKA-6238 which fixes message format upgrade instructions

Repository: kafka-site Updated Branches: refs/heads/asf-site 606a0afdf -> 2fb544c1e Sync KAFKA-6238 which fixes message format upgrade instructions Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/2fb544c1 Tree:

kafka git commit: KAFKA-5936; KafkaProducer.close should throw InterruptException

Repository: kafka Updated Branches: refs/heads/trunk b512cd474 -> 38c5d7fba KAFKA-5936; KafkaProducer.close should throw InterruptException Author: Matthias J. Sax Reviewers: Apurva Mehta , Guozhang Wang , Jason Gustafson

kafka git commit: KAFKA-6260; Ensure selection keys are removed from all collections on socket close

Repository: kafka Updated Branches: refs/heads/trunk 18e34482e -> d01f01ec6 KAFKA-6260; Ensure selection keys are removed from all collections on socket close When a socket is closed, we must remove corresponding selection keys from internal collections. This fixes an NPE which is caused by

kafka git commit: KAFKA-6260; Ensure selection keys are removed from all collections on socket close

Repository: kafka Updated Branches: refs/heads/1.0 df9035fb0 -> 78379c3ba KAFKA-6260; Ensure selection keys are removed from all collections on socket close When a socket is closed, we must remove corresponding selection keys from internal collections. This fixes an NPE which is caused by

kafka git commit: KAFKA-6296; Increase jitter to fix transient failure in NetworkClientTest.testConnectionDelayDisconnected

Repository: kafka Updated Branches: refs/heads/trunk d01f01ec6 -> 8c1e1cf27 KAFKA-6296; Increase jitter to fix transient failure in NetworkClientTest.testConnectionDelayDisconnected Author: Jason Gustafson Reviewers: Ted Yu , Ewen Cheslack-Postava

kafka git commit: KAFKA-6308; Connect Struct should use deepEquals/deepHashCode

Repository: kafka Updated Branches: refs/heads/trunk 616321bcb -> 68712dcde KAFKA-6308; Connect Struct should use deepEquals/deepHashCode This changes the Struct's equals and hashCode method to use Arrays#deepEquals and Arrays#deepHashCode, respectively. This resolves a problem where two

kafka git commit: KAFKA-6102; Consolidate MockTime implementations between connect and clients

Repository: kafka Updated Branches: refs/heads/trunk 1cf7ec87d -> 616321bcb KAFKA-6102; Consolidate MockTime implementations between connect and clients Author: Colin P. Mccabe Reviewers: Randall Hauch , Jason Gustafson Closes

kafka git commit: KAFKA-6258; SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data

Repository: kafka Updated Branches: refs/heads/1.0 a64a69327 -> 45a7bb02f KAFKA-6258; SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data When consumer uses plaintext and there is remaining data in consumer's buffer,

kafka git commit: KAFKA-6258; SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data

Repository: kafka Updated Branches: refs/heads/trunk e86f70ed2 -> 066bfc314 KAFKA-6258; SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data When consumer uses plaintext and there is remaining data in consumer's buffer,

kafka git commit: KAFKA-5526; Additional `--describe` views for ConsumerGroupCommand (KIP-175)

Repository: kafka Updated Branches: refs/heads/trunk 69777260e -> 529786638 KAFKA-5526; Additional `--describe` views for ConsumerGroupCommand (KIP-175) The `--describe` option of ConsumerGroupCommand is expanded, as proposed in

kafka git commit: KAFKA-5764; Add toLowerCase support to sasl.kerberos.principal.to.local rule (KIP-203)

Repository: kafka Updated Branches: refs/heads/trunk 0a508a436 -> b08882213 KAFKA-5764; Add toLowerCase support to sasl.kerberos.principal.to.local rule (KIP-203) Author: Manikumar Reddy Reviewers: Jason Gustafson Closes #3800 from

kafka git commit: MINOR: Increase number of messages in replica verification tool test

Repository: kafka Updated Branches: refs/heads/1.0 46fc8eca9 -> 3420cb3be MINOR: Increase number of messages in replica verification tool test Increase the number of messages produced to make the test more reliable. The test failed in a recent build and also fails intermittently when run

kafka git commit: MINOR: Increase number of messages in replica verification tool test

Repository: kafka Updated Branches: refs/heads/0.11.0 b81bf0e3d -> ef97ed7ee MINOR: Increase number of messages in replica verification tool test Increase the number of messages produced to make the test more reliable. The test failed in a recent build and also fails intermittently when run

kafka git commit: MINOR: Increase number of messages in replica verification tool test

Repository: kafka Updated Branches: refs/heads/trunk 043951753 -> e5741b90c MINOR: Increase number of messages in replica verification tool test Increase the number of messages produced to make the test more reliable. The test failed in a recent build and also fails intermittently when run

kafka git commit: MINOR: Fix inconsistency in StopReplica/LeaderAndIsr error counts

Repository: kafka Updated Branches: refs/heads/trunk c7ab3efcb -> 71fe23b44 MINOR: Fix inconsistency in StopReplica/LeaderAndIsr error counts Author: Jason Gustafson Reviewers: Ismael Juma Closes #4147 from hachikuji/fix-error-inconsistencies

kafka git commit: MINOR: Tighten up locking when aborting expired transactions

Repository: kafka Updated Branches: refs/heads/trunk 71fe23b44 -> 3c9e30a2f MINOR: Tighten up locking when aborting expired transactions This is a followup to #4137 Author: Apurva Mehta Reviewers: Ismael Juma , Jason Gustafson

kafka git commit: KAFKA-2903; FileRecords.read doesn't handle size > sizeInBytes when start is not zero

Repository: kafka Updated Branches: refs/heads/trunk 6118ecb59 -> 8e4b3dca7 KAFKA-2903; FileRecords.read doesn't handle size > sizeInBytes when start is not zero Author: Ismael Juma Reviewers: Jason Gustafson Closes #4158 from

[kafka] branch 1.0 updated: KAFKA-6857; Leader should reply with undefined offset if undefined leader epoch requested (#4967)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch 1.0 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/1.0 by this push: new b4f KAFKA-6857; Leader should reply with undefined

[kafka] branch trunk updated: KAFKA-6867; Corrected the typos in upgrade.html (#4970)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 03a2d82 KAFKA-6867; Corrected the typos

[kafka] branch trunk updated: KAFKA-6292; Improve FileLogInputStream batch position checks to avoid type overflow (#4928)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new fcb15e3 KAFKA-6292; Improve FileLogInputStream

[kafka] branch trunk updated: KAFKA-6299; Fix AdminClient error handling when metadata changes (#4295)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new abbd53d KAFKA-6299; Fix AdminClient error handling

[kafka] branch trunk updated: MINOR: Update dynamic broker configuration doc for truststore update (#4954)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 830ee16 MINOR: Update dynamic broker configuration

[kafka] branch trunk updated: MINOR: Fix typo in ConsumerRebalanceListener JavaDoc (#4996)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new c90bbc2 MINOR: Fix typo

[kafka] branch trunk updated: KAFKA-6893; Create processors before starting acceptor in SocketServer (#4999)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 7ed7cca KAFKA-6893; Create processors before

[kafka] branch 1.1 updated: KAFKA-6893; Create processors before starting acceptor in SocketServer (#4999)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch 1.1 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/1.1 by this push: new 9996f2e KAFKA-6893; Create processors before starting

[kafka] branch trunk updated: MINOR: A few small cleanups in AdminClient from KAFKA-6299 (#4989)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new a5ea6d1 MINOR: A few small cleanups in AdminClient

[kafka] branch trunk updated: KAFKA-6394; Add a check to prevent misconfiguration of advertised listeners (#4897)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new ec7ba32 KAFKA-6394; Add a check to prevent

[kafka] branch trunk updated: KAFKA-6868; Fix buffer underflow and expose group state in the consumer groups API (#4980)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 16ad358 KAFKA-6868; Fix buffer underflow and expose

[kafka] branch trunk updated: MINOR: Fix transiently failing consumer group admin integration test (#5067)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new e884720 MINOR: Fix transiently failing consumer

[kafka] branch trunk updated: KAFKA-2951; Add a test to verify produce, consume with ACLs for topic/group wildcard resources (#5054)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new d45d7ec KAFKA-2951; Add a test to verify produce

[kafka] branch trunk updated: KAFKA-6911; Fix dynamic keystore/truststore update check (#5029)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new ff9f928 KAFKA-6911; Fix dynamic keystore/truststore

[kafka] branch trunk updated: KAFKA-2061; Offer a --version flag to print the kafka version [KIP-278] (#639)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 440445e KAFKA-2061; Offer a --version flag to print

[kafka] branch 0.11.0 updated: KAFKA-6917; Process txn completion asynchronously to avoid deadlock (#5036)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch 0.11.0 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/0.11.0 by this push: new 66680d3 KAFKA-6917; Process txn completion

[kafka] branch trunk updated: KAFKA-6917; Process txn completion asynchronously to avoid deadlock (#5036)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new c53e274 KAFKA-6917; Process txn completion

[kafka] branch 1.1 updated: KAFKA-6917; Process txn completion asynchronously to avoid deadlock (#5036)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch 1.1 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/1.1 by this push: new be58d73 KAFKA-6917; Process txn completion

[kafka] branch 1.0 updated: KAFKA-6917; Process txn completion asynchronously to avoid deadlock (#5036)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch 1.0 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/1.0 by this push: new bb47d39 KAFKA-6917; Process txn completion

[kafka] branch trunk updated: MINOR: AdminClient consumer group domain objects should have public constructors (#5063)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 5be47a2 MINOR: AdminClient consumer group domain

<    1   2   3   4   5   6   7   8   9   10   >