GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3945
MINOR: Move ChannelState.exception() to its own class
Given that Java doesn't support pattern matching, the benefit
is not as clear.
Also implemented ChannelState.toString and re
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3954
KAFKA-5758: Don't fail fetch request if replica is no longer a follower for
a partition
We log a warning instead, which is what we also do if the partition hasn't
been created
yet
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3989
KAFKA-5746; Fix conversion count computed in `downConvert`
It should be the number of records instead of the
number of batches.
A few additional clean-ups: minor renames,
removal of
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3996
KAFKA-5746; Return 0.0 from Metric.value() instead of throwing exception
This is less likely to break custom metric reporters and since the method
is deprecated, people will be warned about this
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4007
MINOR: Java 9 version handling improvements
- Upgrade Gradle to 4.2.1, which handles Azul Zulu 9's version
correctly.
- Add tests to our Java version handling code
- Refactor the co
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4016
MINOR: Simplify log cleaner and fix compiler warnings
- Simplify LogCleaner.cleanSegments and add comment regarding thread
unsafe usage of `LogSegment.append`. This was a result of investigating
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4023
KAFKA-5829: Only delete producer snapshots before the recovery point
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka
kafka-5829
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4034
MINOR: Remove TLS renegotiation code
This has been disabled since the start and since
it's removed in TLS 1.3, there are no plans to
ever support it.
You can merge this pull request i
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4040
KAFKA-5829; Remove stray `printStackTrace()` in test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka kafka-5829-follow-up
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4066
MINOR: Don't register signal handlers if running on Windows
Also remove stray printStackTrace in test.
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4067
MINOR: Merge script improvements
- Remove "list commits" since we never use it
- Fix release branch detection to just look
for branches that start with digits
- Make script execu
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4087
MINOR: Remove dead code
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka remove-dead-code
Alternatively you can review and apply
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4088
MINOR: Controller and async ZookeeperClient improvements (WIP)
More to come.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka async
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4097
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.
You can merge this
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4102
MINOR: Update Scala to 2.12.4
Mainly for Java 9 fixes and improved compilation times (5-10% reduction).
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4112
MINOR: Rename ZookeeperClient to ZooKeeperClient and move it to
kafka.zookeeper
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4117
MINOR: Configure owasp.dependencycheck gradle plugin
It seems to output a few false positives, but still
worth verifying.
You can merge this pull request into a Git repository by running
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4138
MINOR: Revert EmbeddedZooKeeper rename
Even though this class is internal, it's widely
used by other projects and it's better to avoid
breaking them until we have a publicly supporte
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4142
MINOR: Use Scala Future in CoreUtils test
Also rename UtilsTest to CoreUtilsTest and note
that `getOrElseUpdate` has the right behaviour
in Scala 2.12.
You can merge this pull request into a
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4143
MINOR: PartitionReassignmentHandler should generate event only when znode
is created and eliminate unnecessary allocations
As suggested by Jun in https://github.com/apache/kafka/pull/4141, we
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4144
MINOR: Ensure that the producer in testAlterReplicaLogDirs is always closed
Failure to close the producer could cause a transient failure, more details
below.
The request timeout was only
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4152
MINOR: Eliminate unnecessary Topic(And)Partition allocations in Controller
- Eliminated all the unnecessary allocations of `TopicPartition` and
`TopicAndPartition` in the Controller. We now use
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4154
KAFKA-4203: Align broker default for max.message.bytes with Java producer
default
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4158
KAFKA-2903: FileRecords.read doesn't handle size > sizeInBytes when start
is not zero
You can merge this pull request into a Git repository by running:
$ git pull https://github.c
Github user ijuma commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/107#discussion_r148303219
--- Diff: 10/documentation.html ---
@@ -0,0 +1,83 @@
+
+
+<!--#include virtual="js/templat
Github user ijuma commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/107#discussion_r148303944
--- Diff: downloads.html ---
@@ -9,48 +9,75 @@
You can verify your download by following these http://www.apache.org/info
Github user ijuma commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/107#discussion_r148303796
--- Diff: downloads.html ---
@@ -9,48 +9,75 @@
You can verify your download by following these http://www.apache.org/info
Github user ijuma commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/107#discussion_r148393662
--- Diff: 10/documentation.html ---
@@ -69,15 +69,15 @@
8. Kafka Connect
-9. Kafka
Streams
+9. Kafka
Streams
Github user ijuma commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/107#discussion_r148400321
--- Diff: 100/javadoc/script.js ---
@@ -1,30 +0,0 @@
-function show(type)
-{
-count = 0;
-for (var key in methods
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4172
MINOR: Remove clients/out directory
It was committed inadvertently.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka remove-out-folder
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4174
MINOR: Add pull request template
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka pull-request-template
Alternatively you can review
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4185
MINOR: Update Scala 2.11 to 2.11.12
The main change is Java 9 support.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka scala-2.11.12
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4192
MINOR: Remove unnecessary batch iteration in FileRecords.downConvert
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka
avoid
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4200
MINOR: Update to Scala 2.11.12 (part 2)
Missed a few places in the previous commit.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka
Github user ijuma closed the pull request at:
https://github.com/apache/kafka/pull/551
---
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4201
MINOR: Exclude PULL_REQUEST_TEMPLATE.md from rat checks
### Committer Checklist
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4202
MINOR: Exclude Committer Checklist section from commit message
### Committer Checklist
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4219
MINOR: Fix NPE in unregisterPartitionReassignmentIsrChangeHandlers
I was looking at a transient failures of
`shouldPerformMultipleReassignmentOperationsOverVariousTopics`
and came across a NPE
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4220
KAFKA-6210: IllegalArgumentException if 1.0.0 is used for
inter.broker.protocol.version or log.message.format.version
Added unit test for ApiVersion and testApiVersions from
Scala to Java
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4250
KAFKA-6261: Fix exception thrown by request logging if acks=0
Only expect responseAsString to be set if request logging is
enabled _and_ responseSend is defined.
Also fixed a couple of
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4261
MINOR: Avoid intermediate strings when parsing/decoding ZK JSON
Also:
- Fix bug in result type of `createSequentialPersistentPath`
- Remove duplicated code from `ReplicationUtils`
- Move
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4262
MINOR: Temporarily disable testLogStartOffsetCheckpoint
It's failing often and it seems like there are multiple
reasons. PR #4238 will re-enable it.
### Committer Checklist (excluded
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4265
KAFKA-6065: Latency metric for KafkaZkClient
Measures the latency of each request batch.
Updated existing `ZkUtils` test to use `KafkaZkClient`
instead.
### Committer Checklist
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4283
(WIP) KAFKA-6193: Flaky
shouldPerformMultipleReassignmentOperationsOverVariousTopics
I have been unable to reproduce it locally, so enabled additional
logging while running it in Jenkins
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4297
KAFKA-6317: Maven artifact for kafka should not depend on log4j
It should only depend on slf4j-api (like kafka-clients). The
release tarball still includes log4j and slf4j-log4j12
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4345
KAFKA-6390: Update ZooKeeper to 3.4.11, Gradle and other minor updates
Updates:
- Gradle, gradle plugins and maven artifact updated
- Bug fix updates for ZooKeeper, Jackson, EasyMock and
Github user ijuma commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/60#discussion_r121246131
--- Diff: 0110/design.html ---
@@ -261,15 +262,23 @@
It can read the messages, process the messages, and finally save
its position. In this case
Github user ijuma commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/60#discussion_r121246230
--- Diff: 0110/design.html ---
@@ -261,15 +262,23 @@
It can read the messages, process the messages, and finally save
its position. In this case
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3299
MINOR: Remove unused `AdminUtils.fetchTopicMetadataFromZk` methods
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka remove-unused
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3316
[WIP] KAFKA-5274: AdminClient Javadoc improvements
Also improve the Javadoc for ExtendedSerializer, ExtendedDeserializer
and InterfaceStability.
Publish Javadoc for common.annotation
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3330
MINOR: Javadoc for ExtendedSerializer and ExtendedDeserializer
And add warning about usage.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3339
KAFKA-5275: AdminClient API consistency
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka
kafka-5275-admin-client-api-consistency
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3341
MINOR: Update `TransactionMarkerChannelManager` metric name
Also remove broker-id tags as we generally use them to provide
additional context.
Finally, do a few clean-ups (could not
Github user ijuma commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/60#discussion_r122096607
--- Diff: 0110/design.html ---
@@ -264,21 +264,22 @@
messages have a primary key and so the updates are idempotent
(receiving the same message
Github user ijuma commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/60#discussion_r122096221
--- Diff: 0110/design.html ---
@@ -264,21 +264,22 @@
messages have a primary key and so the updates are idempotent
(receiving the same message
Github user ijuma commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/60#discussion_r122096525
--- Diff: 0110/design.html ---
@@ -264,21 +264,22 @@
messages have a primary key and so the updates are idempotent
(receiving the same message
Github user ijuma commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/60#discussion_r122096399
--- Diff: 0110/design.html ---
@@ -264,21 +264,22 @@
messages have a primary key and so the updates are idempotent
(receiving the same message
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3347
MINOR: Upgrade to Gradle 4.0
Among other things, it includes performance
and CLI improvements.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3364
HOTFIX: Use ResourceType.toJava instead of ResourceType.fromString
The latter doesn't work for TransactionalId (or any type with two camel-case
words).
You can merge this pull request into
Github user ijuma closed the pull request at:
https://github.com/apache/kafka/pull/3347
---
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 is
Github user ijuma commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/62#discussion_r122709472
--- Diff: contact.html ---
@@ -19,6 +19,9 @@
comm...@kafka.apache.org: A list to track Kafka
commits. To
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3371
KAFKA-5470: Replace -XX:+DisableExplicitGC with
-XX:+ExplicitGCInvokesConcurrent in kafka-run-class
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3402
KAFKA-5486: org.apache.kafka logging should go to server.log
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka
kafka-5486
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3408
KAFKA-5490: Skip empty record batches in the consumer
The proper fix for KAFKA-5490 (including tests) is in
https://github.com/apache/kafka/pull/3406.
This is just the consumer change
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3409
MINOR: Switch ZK client logging to INFO
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka tweak-log-config
Alternatively you can
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3420
KAFKA-5506: Fix NPE in OffsetFetchRequest.toString
Also avoid eager toString call in parameter passed to log.debug.
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3422
MINOR: SaslChannelBuilder should be idempotent
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka sasl-channel-builder-idempotent
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3431
MINOR: Adjust checkstyle suppression paths to work on Windows
Use the file name whenever possible and replace / with [/\\]
when it's not.
Also remove unnecessary suppresions.
Yo
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3446
MINOR: Improve TransactionIndex.sanityCheck() message
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka
improve-transaction-index
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3451
MINOR: Implement `toString` in some Validator instances
This is used in the generated config table. Also fix a couple
of typos in the process.
You can merge this pull request into a Git
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3454
MINOR: Compatibility and upgrade tests for 0.11.0.x
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka test-upgrades-from-0.11.0.x
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3464
MINOR: Enable a number of xlint scalac warnings
Update the code where possible to fix the warnings. The unused
warning introduced in Scala 2.12 is quite handy and provides
a reason to compile
Github user ijuma commented on the issue:
https://github.com/apache/kafka-site/pull/64
Good idea. As you said, the dates seem to differ slightly from:
https://issues.apache.org/jira/browse/KAFKA/?selectedTab=com.atlassian.jira.jira-projects-plugin:versions-panel
It would be
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3501
MINOR: Improve versioning in docs when a full version is required
Also fix quickstart.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3503
KAFKA-5570: Join request's timeout should be slightly higher than the
rebalance timeout
- Introduce per request timeouts in NetworkClient
- Use rebalanceTimeout + 5s for join request ti
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3527
MINOR: Mention systemTestLibs in docker system test instructions
Otherwise NoClassFoundExceptions are thrown for tests that attempt
to start MiniKdc.
You can merge this pull request into a Git
Github user ijuma closed the pull request at:
https://github.com/apache/kafka/pull/3527
---
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 is
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3543
MINOR: Remove flaky assertion in
verifyCloseOldestConnectionWithStagedReceives
This seems to fail a lot in Jenkins although it always passes locally
for me. Removing the assertion to restore
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3552
MINOR: Simplify SensorAccess usage
I was investigating an exception in this code and found a few
opportunities for making it clearer.
I also added the `out` folder to `.gitignore` as
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3553
KAFKA-5608: Follow-up to fix potential NPE and clarify method name
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka kafka-5608-follow
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3560
MINOR: Improve log warning to include the log name
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka tweak-log-and-upgrade-note
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3561
MINOR: Give correct instructions for retaining previous unclear leader
election behaviour
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma
Github user ijuma closed the pull request at:
https://github.com/apache/kafka/pull/3560
---
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 is
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3562
MINOR: Improve log warning to include the log name
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka tweak-log-warning
Alternatively
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3572
MINOR: Remove unused GroupState.state field
This field doesn't seem to be used and the value for
`AwaitingSync` seems to be wrong (it seems like it
should have been `2` instead of `5`).
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3579
Bump version to 0.11.0.1-SNAPSHOT
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka bump-to-0.11.0.1-SNAPSHOT
Alternatively you can
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3580
MINOR: Next release will be 1.0.0
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka bump-to-1.0.0-SNAPSHOT
Alternatively you can
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3587
MINOR: Support versions with 3 segments in _kafka_jar_versions
The bump from 0.11.1.0-SNAPSHOT to 1.0.0-SNAPSHOT broker a couple
of tests:
* TestVerifiableProducer.test_simple_run
Github user ijuma closed the pull request at:
https://github.com/apache/kafka/pull/3579
---
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 is
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3595
MINOR: Request log should be enabled by debug level
At some point, we lost the ability to output request
logging at debug level (which is a little less
verbose than at trace level).
You can
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3596
MINOR: Null out all buffer references in RequestChannel.Request
The previous code kept two references to `Buffer` and only nulled
out one of them.
You can merge this pull request into a Git
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3609
MINOR: Only log about marking replicas as offline if there is a replica
I noticed a bunch of these log messages with an empty set for the replicas.
You can merge this pull request into a Git
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3619
MINOR: Update dependencies for 1.0.0 release
Notable updates:
1. Gradle 4.1 includes a number of performance and
CLI improvements as well as initial Java 9 support.
There's als
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3634
MINOR: Deprecate LogConfig.Compact
It actually refers to the `delete` cleanup policy.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3647
KAFKA-4501: Java 9 compilation fixes
Compilation fixes:
- Avoid ambiguity error when appending to Properties in Scala code
- Use position() and limit() to fix ambiguity issue
- Disable
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3658
MINOR: AdminClient should register with `AppInfoParser`
Also make "created" message more consistent across clients.
You can merge this pull request into a Git repository by running:
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3706
KAFKA-5753: ShellTest.testRunProgramWithErrorReturn fails on macOS
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka fix-shell-test-mac
Github user ijuma commented on the issue:
https://github.com/apache/kafka-site/pull/71
Thanks for the PR, we also need to fix it in the main repo:
https://github.com/apache/kafka/blob/0.10.2/docs/upgrade.html#L90
---
If your project is set up for it, you can reply to this email and
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3734
KAFKA-5785; Always close connection if KafkaChannel.setSend throws exception
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka
kafka
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3738
MINOR: Remove try/finally from processNewResponses
The previous code would skip a response if an exception was thrown.
You can merge this pull request into a Git repository by running:
$ git
1 - 100 of 506 matches
Mail list logo
