GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3942
KAFKA-5957: Prevent second deallocate if response for aborted batch returns
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3944
KAFKA-5960 [WIP]; Fix regression in produce version selection on old brokers
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3976
MINOR: Follow-up cleanup of KAFKA-5960
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka version-fix-followup
Alternatively
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/4047
MINOR: Factor out some common group/transactional fields in request objects
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/4076
MINOR: A few javadoc fixes
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka javadoc-fixes
Alternatively you can review and
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/4141
KAFKA-6134: Read partition reassignment lazily on event handling
This patch prevents an O(n^2) increase in memory utilization during
partition reassignment. Instead of storing the reassigned
Github user hachikuji closed the pull request at:
https://github.com/apache/kafka/pull/4141
---
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/4147
MINOR: Fix inconsistency in StopReplica/LeaderAndIsr error counts
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka fix-error
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/4256
KAFKA-6328: Fix 1.0.0 upgrade instructions relating to the message format
version
The upgrade instructions concerning the message format versions did not
account for upgrades from versions prior
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/4276
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
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/4280
KAFKA-6289: NetworkClient should not expose failed internal ApiVersions
requests
The NetworkClient internally ApiVersion requests to each broker following
connection establishment. If this
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/4285
KAFKA-6296: Increase jitter to fix transient failure in
NetworkClientTest.testConnectionDelayDisconnected
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/4287
KAFKA-6118: Fix transient failure
testTwoConsumersWithDifferentSaslCredentials
It's rare, but it can happen that the initial FindCoordinator request
returns before the first Metadata re
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/4349
KAFKA-6366 [WIP]: Fix stack overflow in consumer due to fast offset commits
during coordinator disconnect
When the coordinator is marked unknown, we explicitly disconnect its
connection and
Github user hachikuji commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/60#discussion_r121249508
--- Diff: 0110/design.html ---
@@ -261,15 +262,23 @@
It can read the messages, process the messages, and finally save
its position. In this
Github user hachikuji commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/60#discussion_r121249550
--- Diff: 0110/design.html ---
@@ -261,15 +262,23 @@
It can read the messages, process the messages, and finally save
its position. In this
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3297
KAFKA-5427: Transactional producer should allow FindCoordinator in error
state
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3298
KAFKA-5428: Transactional producer should only abort batches in fatal error
state
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3300
KAFKA-5429: Ignore produce response if batch was previously aborted
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3306
KAFKA-5435: Ensure producer snapshot retained after truncation
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA-5435
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3318
HOTFIX: Fix invalid long format conversion in request logger message
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka hotfix
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3331
KAFKA-5443: Consumer should use last offset from batch to set next fetch
offset
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3340
MINOR: Add random aborts to system test transactional copier service
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
add
Github user hachikuji commented on the issue:
https://github.com/apache/kafka-site/pull/60
@guozhangwang @ijuma @apurvam Pushed a couple changes based on the review.
Please take another look.
---
If your project is set up for it, you can reply to this email and have your
reply
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3348
MINOR: Fix unsafe access to incomplete collection in RecordAccumulator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
fix
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3356
KAFKA-5456: Ensure producer handles old format large compressed messages
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
Github user hachikuji closed the pull request at:
https://github.com/apache/kafka/pull/3306
---
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 hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3361
KAFKA-5435: Improve producer state loading after failure
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA-5435-ALT
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3363
MINOR: Some small cleanups/improvements to KAFKA-5031
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA-5031-FOLLOWUP
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3373
MINOR: Detail message/batch size implications for conversion between old
and new formats
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user hachikuji commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/60#discussion_r122825810
--- 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 hachikuji commented on a diff in the pull request:
https://github.com/apache/kafka-site/pull/60#discussion_r122826323
--- 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 hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3376
MINOR: MemoryRecordsBuilder.sizeInBytes should consider initial position
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
Github user hachikuji commented on the issue:
https://github.com/apache/kafka-site/pull/60
I'm going to reopen this as a PR against kafka since that is where
design.html is maintained.
---
If your project is set up for it, you can reply to this email and have your
reply appe
Github user hachikuji closed the pull request at:
https://github.com/apache/kafka-site/pull/60
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3388
KAFKA-5021: Update delivery semantics documentation for EoS (KIP-98)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3406
KAFKA-5490: Retain empty batch for last sequence of each producer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA-5490
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3426
MINOR: Fix race condition in KafkaConsumer close
We intended to make `KafkaConsumer.close()` idempotent, but due to the fact
that the `closed` variable is checked without a lock prior to
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3456
KAFKA-5522: ListOffsets should bound timestamp search by LSO in
read_committed
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3457
MINOR: Rename baseTimestamp to firstTimestamp to clarify usage
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka rename-base
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3558
MINOR: Safer handling of requests prior to SASL authentication
This implements two improvements for request handling prior to SASL
authentication:
1. Only parse request types that are
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3571
KAFKA-5611; AbstractCoordinator should handle wakeup raised from
onJoinComplete
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3575
KAFKA-5634; Do not allow segment deletion beyond high watermark
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA-5634
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3612
MINOR: Remove legacy ControlledShutdown request/response objects
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
remove-old
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3627
MINOR: Fix error response handler for controlled shutdown v0
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
minor-fix
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3646
MINOR: Remove unneeded error handlers in deprecated request objects
These handlers were previously used on the broker to handle uncaught
exceptions, but now the broker users the new Java request
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3651
MINOR: Add missing deprecations on old request objects
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
add-missing-request
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3665
HOTFIX: ConsoleConsumer using wrong old consumer config value for
auto.offset.reset
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3666
KAFKA-5730: Consumer should invoke async commit callback before sync commit
returns
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3673
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
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3676
MINOR: Ensure consumer logging has clientId/groupId context
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka log-consumer
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3688
KAFKA-5747: Producer snapshot loading should cover schema and other errors
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3716
KAFKA-5342: Clarify fatal/abortable exceptions used in producer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA-5342
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka-site/pull/72
Jason and Becket are PMC members
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka-site update-pmc-members
Alternatively
Github user hachikuji closed the pull request at:
https://github.com/apache/kafka-site/pull/72
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3778
KAFKA-5822: Consistent log formatting of topic partitions
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA-5822
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3795
KAFKA-5783: Add KafkaPrincipalBuilder with support for SASL (KIP-189)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3813
MINOR: Move request/response schemas to the corresponding object
representation
This refactor achieves the following:
1. Breaks up the increasingly unmanageable `Protocol` class.
2
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3852
MINOR: Update TransactionManager to use LogContext
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
minor-use-log-context-txn
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3863
MINOR: Use SecurityProtocol in AuthenticationContext
Since we removed the unused `TRACE` option from `SecurityProtocol`, it now
seems safer to expose it from `AuthenticationContext`. Additionally
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/1427
KAFKA-2720 [WIP]: expire group metadata when all offsets have expired
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/1452
HOTFIX: remove from inflightResponses on client disconnect to prevent
memory leak
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji
GitHub user hachikuji reopened a pull request:
https://github.com/apache/kafka/pull/1452
KAFKA-3773: Remove from inflightResponses on client disconnect to prevent
memory leak
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user hachikuji closed the pull request at:
https://github.com/apache/kafka/pull/1452
---
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 hachikuji closed the pull request at:
https://github.com/apache/kafka/pull/1452
---
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 hachikuji opened a pull request:
https://github.com/apache/kafka/pull/1511
KAFKA-: WorkerSinkTask commit prior to rebalance should be retried on
wakeup
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji
GitHub user hachikuji reopened a pull request:
https://github.com/apache/kafka/pull/1511
KAFKA-3850: WorkerSinkTask commit prior to rebalance should be retried on
wakeup
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji
Github user hachikuji closed the pull request at:
https://github.com/apache/kafka/pull/1511
---
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 hachikuji opened a pull request:
https://github.com/apache/kafka/pull/1513
MINOR: Follow-up from KAFKA-2720 with comment/style fixes
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka followup-for-kafka
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/1518
KAFKA-3632; remove fetcher metrics on shutdown and leader migration
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka port
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/1519
KAFKA-3863: System tests covering connector/task failure and restart
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA
Github user hachikuji closed the pull request at:
https://github.com/apache/kafka/pull/1518
---
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 hachikuji opened a pull request:
https://github.com/apache/kafka/pull/1531
KAFKA-3865: Fix transient failure in WorkerSourceTaskTest.testSlowTaskStart
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/1627
KAFKA-3888: send consumer heartbeats from a background thread (KIP-62)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/1650
KAFKA-3782: Fix transient failure in connect distributed bounce test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/1656
KAFKA-3977: Defer fetch parsing for space efficiency and to ensure
exceptions are raised to the user
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/1676
MINOR: Consumer should throw KafkaException on invalid checksum
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
raise-kafka
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2140
KAFKA-4390: Replace MessageSet usage with client-side alternatives
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA4390
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2190
KAFKA-4469: Fix consumer performance regression from unneeded list copy
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2195
KAFKA-3994: Fix deadlock in Watchers by calling tryComplete without any
locks
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji
Github user hachikuji closed the pull request at:
https://github.com/apache/kafka/pull/1738
---
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 hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2202
MINOR: Improvements in group metadata cleanup and test coverage
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka group
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2279
KAFKA-4166: Fix transient MM failure caused by slow old consumer shutdown
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2282
MINOR: Support auto-incrementing offsets in MemoryRecordsBuilder
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka builder
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2596
MINOR: Ensure consumer calls poll() if requests are outstanding
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
ensure-poll
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2614
KAFKA-4816: Message format changes for idempotent/transactional producer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/confluentinc/kafka
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2646
MINOR: Rename RecordBatch to ProducerBatch to allow reuse in KIP-98
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka rename
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2647
MINOR: Add varint serde utilities for new message format
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka add-varint-serdes
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2656
MINOR: Use ConcurrentMap for ConsumerNetworkClient UnsentRequests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka minor
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2736
HOTFIX: Fix unsafe dependence on class name in VerifiableClientJava
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka hotfix
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2738
MINOR: Support streaming decompression of fetched records for new format
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2745
MINOR: Replication system tests should cover compressed path
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
add-replication
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2762
MINOR: Ensure streaming iterator is closed by Fetcher
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
ensure-decompression
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2771
KAFKA-4689: Disable system tests for consumer hard failures
See the JIRA for the full details. Essentially the test assertions depend
on receiving reliable events from the consumer processes, but
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2866
MINOR: Improvements to PID snapshot management
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka improve-snapshot-management
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2870
MINOR: Fix open file leak in log cleaner integration tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka fix-log-cleaner
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2881
MINOR: Remove redundant CRC validation for non-compressed records in older
message formats
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2892
KAFKA-5110: Check for errors when fetching the log end offset in
ConsumerGroupCommand
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2348
MINOR: Minor improvements in consumer close timeout handling
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka minor-cleanup
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2372
MINOR: Remove unneeded client used API lists
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka minor-cleanup-used-apis
1 - 100 of 321 matches
Mail list logo