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 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/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/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/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/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/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 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/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 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/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/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/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/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/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/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/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/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/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 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-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 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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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/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 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 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 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 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 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 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 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/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 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/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 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 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/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 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/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/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/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/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/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 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 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 opened a pull request:
https://github.com/apache/kafka/pull/3284
MINOR: A few cleanups of usage of Either in TC
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka minor-either-usage-cleanup
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3277
KAFKA-5414: Revert "KAFKA-5327: ConsoleConsumer should manually commiâ¦
â¦t offsets for records that are returned in receive()"
This reve
Github user hachikuji commented on the issue:
https://github.com/apache/kafka-site/pull/60
cc @guozhangwang @apurva @ijuma
---
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
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka-site/pull/60
Update delivery semantics section for KIP-98
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka-site update-delivery
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3259
MINOR: A few logging improvements in group coordinator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
group-coordinator
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3248
KAFKA-5378: Return LSO in FetchResponse plus some metrics
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA-5378
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3239
KAFKA-5376: Ensure aborted transactions are propagated in DelayedFetch
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/3231
KAFKA-5364: ensurePartitionAdded does not handle pending partitions in
abortable error state
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/3230
KAFKA-5355: Test cases to ensure isolation level propagated in delayed fetch
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/3221
KAFKA-5355: DelayedFetch should propagate isolation level to log read
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/3212
KAFKA-5019: Upgrades notes for idempotent/transactional features and new
message format
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/3203
KAFKA-5365 [WIP]: Fix regression in compressed message iteration affecting
magic v0 and v1
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/3165
---
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/3185
MINOR: Logging/debugging improvements for transactions
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
minor-transaction
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3183
KAFKA-5283: Handle producer epoch/sequence overflow by wrapping around
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/3175
KAFKA-5349: Fix illegal state error in consumer's ListOffset handler
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/3171
MINOR: A few cleanups in KafkaApis and TransactionMarkerChannelManager
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/3165
KAFKA-5316: LogCleaner should account for larger record sets after cleaning
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/3162
KAFKA-5340: Batch splitting should preserve magic and transactional flag
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/3161
KAFKA-5251: Producer should cancel unsent AddPartitions and Produce
requests on abort
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/3160
KAFKA-5093: Avoid loading full batch data when possible when iterating
FileRecords
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/3145
MINOR: Add test case for duplicate check after log cleaning
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
minor-improve
Github user hachikuji closed the pull request at:
https://github.com/apache/kafka/pull/3138
---
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/3142
KAFKA-5316: LogCleaner should account for larger record sets after cleaning
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/3138
KAFKA-5017: Record batch first offset remains accurate after compaction
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/3133
MINOR: GroupCoordinator can append with group lock
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
minor-replica-manager
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3123
KAFKA-4935 [WIP]: Deprecate client checksum API and compute lazy partial
checksum for magic v2
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/3118
MINOR: Broker should disallow downconversion of transactional/idempotent
records
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/3113
KAFKA-5186: Avoid expensive log scan to build producer state when upgrading
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/3089
KAFKA-5268: Fix bounce test transient failure by clearing partitions before
writing Complete state to transaction log
You can merge this pull request into a Git repository by running
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3084
TRIVIAL: Remove redundant asMap utility in ConsumerProtocol
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
trivial-remove
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3081
MINOR: Log transaction metadata state transitions plus a few cleanups
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/3075
KAFKA-5259 [WIP]: TransactionalId auth implies ProducerId auth
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA-5259
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3064
KAFKA-5252: Fix transient failures LogCleanerTest testCommitMarkerRemoval
and testAbortMarkerRemoval
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/3060
KAFKA-5249: Fix incorrect producer snapshot offsets when recovering segments
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/3058
KAFKA-5248: Remove unused/unneeded retention time in TxnOffsetCommitRequest
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/3040
MINOR: Some minor improvements to TxnOffsetCommit handling
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka txn-offset-commit
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3008
KAFKA-5196: Make LogCleaner transaction-aware
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA-5196
Alternatively you
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/2997
MINOR: Rename InitPidRequest/InitPidResponse renamed to
InitProducerIdRequest/InitProducerIdResponse
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/2933
MINOR: Some cleanup in the transactional producer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka
minor-transactional-client
1 - 100 of 321 matches
Mail list logo
