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
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
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
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
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
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:
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:
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
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:
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
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
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
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
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
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
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
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
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:
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
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
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
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
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
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
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
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
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
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
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:
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:
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:
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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`
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
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:
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
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
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
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
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
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
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
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
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
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
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
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
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:
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:
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
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
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
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
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
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
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,
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,
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
501 - 600 of 2118 matches
Mail list logo