Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1847 commits
Select commit Hold shift + click to select a range
5351efe
KAFKA-8407: Fix validation of class and list configs in connector cli…
C0urante May 23, 2019
3696b98
KAFKA-8371: Remove dependence on ReplicaManager from Partition (#6705)
hachikuji May 23, 2019
c823f32
MINOR: Add 2.0, 2.1 and 2.2 to broker and client compat tests
ijuma May 23, 2019
6913290
MINOR: Update jackson to 2.9.9 (#6798)
ijuma May 24, 2019
7df79e1
MINOR: add Kafka Streams upgrade notes for 2.3 release (#6758)
mjsax May 24, 2019
eefb25d
MINOR: Fix a few compiler warnings (#6767)
dongjinleekr May 24, 2019
d286051
MINOR: fix Streams version-probing system test (#6764)
mjsax May 24, 2019
105264b
MINOR: Updated configuration docs with RocksDBConfigSetter#close (#6784)
ableegoldman May 24, 2019
46a02f3
KAFKA-8341. Retry Consumer group operation for NOT_COORDINATOR error …
soondenana May 25, 2019
5ecac84
MINOR: Fix `toString` NPE in tableProcessorNode (#6807)
rodesai May 25, 2019
a180896
KAFKA-8422; Client should send OffsetForLeaderEpoch only if broker su…
hachikuji May 25, 2019
6afb0ca
KAFKA-8351; Cleaner should handle transactions spanning multiple segm…
hachikuji May 25, 2019
e6057e5
KAFKA-8437; Await node api versions before checking if offset validat…
hachikuji May 27, 2019
27943e3
KAFKA-8219: add doc changes for static membership release (#6790)
May 27, 2019
94195f8
HOTFIX: Fix wrong setting of Serde in `MeteredTimestampWindowStore` (…
cadonna May 28, 2019
24f664a
MINOR: Auth operations must be null when talking to a pre-KIP-430 bro…
cmccabe May 28, 2019
88619b7
MINOR: improve error message for Serde type miss match (#6801)
mjsax May 28, 2019
4a3c92b
MINOR: Remove redundant checkpoint thread started field in ReplicaMan…
hachikuji May 28, 2019
901eb36
MINOR: Set default `group.instance.id` in JoinGroupResponse to null (…
May 28, 2019
051379e
KAFKA-8430: unit test to make sure null `group.id` and valid `group.i…
May 28, 2019
592410f
KAFKA-8428: Always require a single batch with un- / compressed messa…
guozhangwang May 29, 2019
efeefa5
MINOR: Check invalid bootstrap-server, alter option and config flags …
stanislavkozlovski May 29, 2019
da6063b
MINOR: Add unit tests to verify setting of serdes in timestamped key-…
cadonna May 29, 2019
348e5d7
MINOR: Fix transient failure in PartitionTest.testAddAndRemoveMetrics…
hachikuji May 29, 2019
121308c
KAFKA-8286; Generalized Leader Election Admin RPC (KIP-460) (#6686)
jsancio May 29, 2019
e7da042
MINOR: Rename unit test class for `MeteredTimestampedWindowStore` (#6…
cadonna May 29, 2019
f249956
MINOR: Account for different versions in upgrade (#6835)
bbejeck May 29, 2019
4838855
MINOR: Fix red herring when ConnectDistributedTest.test_bounce fails.…
avocader May 29, 2019
e82e2e7
KAFKA-7703; position() may return a wrong offset after seekToEnd (#6407)
viktorsomogyi May 29, 2019
91ccbca
[MINOR] Improve docs for Global Store operations (#6803)
ableegoldman May 30, 2019
932a1b7
MINOR: Extend RocksDB section of Memory Management Docs (#6793)
ableegoldman May 30, 2019
9f1ce60
KAFKA-8187: Add wait time for other thread in the same jvm to free th…
May 30, 2019
fd9a20e
KAFKA-8429; Handle offset change when OffsetForLeaderEpoch inflight (…
hachikuji May 30, 2019
77e6e8e
KAFKA-6455: Update integration tests to verify result timestamps (#6751)
mjsax May 30, 2019
77a9a10
KAFKA-8418: Wait until REST resources are loaded when starting a Conn…
avocader May 30, 2019
55bfea1
KAFKA-8155: Add 2.1.1 release to system tests (#6596)
mjsax May 30, 2019
a4c0b18
KAFKA-8389: Remove redundant bookkeeping from MockProcessor (#6761)
guozhangwang May 30, 2019
efa6410
KAFKA-8199: Implement ValueGetter for Suppress (#6781)
vvcephei May 30, 2019
5795675
MINOR:Replace duplicated code with common function in utils (#6819)
May 30, 2019
78c55c8
KAFKA-6958: Overload KStream methods to allow to name operation name …
fhussonnois May 31, 2019
529a5a5
MINOR: Reordering the props modification with configs construction
guozhangwang Jun 1, 2019
87d493f
KAFKA-8446: Kafka Streams restoration crashes with NPE when the recor…
Jun 2, 2019
17345b3
KAFKA-8463: Fix redundant reassignment of tasks when leader worker le…
kkonstantine Jun 2, 2019
2c810e4
KAFKA-8425: Fix for correctly handling immutable maps (KIP-421 bug) (…
tadsul Jun 3, 2019
b042b36
KAFKA-8426; Fix for keeping the ConfigProvider configs consistent wit…
tadsul Jun 3, 2019
3c7c988
KAFKA-8449: Restart tasks on reconfiguration under incremental cooper…
kkonstantine Jun 3, 2019
ce008e7
KAFKA-8475: Temporarily restore SslFactory.sslContext() helper
rhauch Jun 3, 2019
45fae33
KAFKA-8383; Integration tests for unclean `electLeaders` (#6857)
jsancio Jun 3, 2019
17712b9
KAFKA-6819: Pt. 1 - Refactor thread-level Streams metrics (#6631)
cadonna Jun 3, 2019
55d07e7
KAFKA-8473: Adjust Connect system tests for incremental cooperative r…
kkonstantine Jun 3, 2019
573152d
HOTFIX: Allow multi-batches for old format and no compression (#6871)
guozhangwang Jun 3, 2019
1a3fe9a
KAFKA-8404: Add HttpHeader to RestClient HTTP Request and Connector R…
haidangdam Jun 4, 2019
ba3dc49
KAFKA-8155: Add 2.2.0 release to system tests (#6597)
mjsax Jun 4, 2019
055c9c7
KAFKA 8311: better handle timeout exception on Stream thread (#6662)
Jun 4, 2019
e6563aa
KAFKA-4893; Fix deletion and moving of topics with long names
cmccabe Jun 4, 2019
264d1d8
Improve logging in the consumer for epoch updates (#6879)
mumrah Jun 4, 2019
b6d9e15
MINOR: Update docs to say 2.3 (#6881)
cmccabe Jun 4, 2019
8e16158
KAFKA-8305; Support default partitions & replication factor in AdminC…
agavra Jun 5, 2019
fb1f749
KAFKA-8386; Use COORDINATOR_NOT_AVAILABLE error when group is Dead (#…
Jun 5, 2019
0e95c9f
KAFKA-8400; Do not update follower replica state if the log read fail…
hachikuji Jun 5, 2019
59d3a56
Minor: Replace InternalTopicMetadata with InternalTopicConfig (#6886)
ableegoldman Jun 6, 2019
58aa04f
MINOR: Improve Trogdor external command worker docs (#6438)
stanislavkozlovski Jun 6, 2019
30adf2a
HOTFIX: Close unused ColumnFamilyHandle (#6893)
ableegoldman Jun 6, 2019
562424c
MINOR: Remove redundant semicolons in `KafkaApis` imports (#6889)
Wennn Jun 6, 2019
72c3b88
MINOR: Fixed compiler warnings in LogManagerTest (#6897)
Jun 7, 2019
28eccc3
KAFKA-8384; Leader election command integration tests (#6880)
jsancio Jun 7, 2019
060701f
KAFKA-8461: Wait for follower to join the ISR in testUncleanLeaderEle…
omkreddy Jun 7, 2019
07dd7db
MINOR: Increase timeout for flaky ResetConsumerGroupOffsetTest (#6900)
hachikuji Jun 7, 2019
bb8de0b
KAFKA-8003; Fix flaky testFencingOnTransactionExpiration
hachikuji Jun 7, 2019
cca05ca
KAFKA-8331: stream static membership system test (#6877)
Jun 7, 2019
677713b
KAFKA-8499: ensure java is in PATH for ducker system tests (#6898)
lbradstreet Jun 7, 2019
c7c310b
MINOR: Lower producer throughput in flaky upgrade system test
hachikuji Jun 7, 2019
2feb44e
MINOR: Fix race condition on shutdown of verifiable producer
hachikuji Jun 7, 2019
b9c5535
KAFKA-7315 DOCS update TOC internal links serdes all versions (#6875)
londoncalling Jun 10, 2019
1e5227c
MINOR: Fix transient failure in PreferredReplicaLeaderElectionCommand…
hachikuji Jun 10, 2019
0864779
MINOR: Increase timeouts to 30 seconds (#6852)
bbejeck Jun 10, 2019
783ab74
KAFKA-8333; Load high watermark checkpoint lazily when initializing r…
hachikuji Jun 11, 2019
1669b77
KAFKA-8501: Removing key and value from exception message (#6904)
carlosduclos Jun 11, 2019
bebcbe3
KAFKA-8487: Only request re-join on REBALANCE_IN_PROGRESS in CommitOf…
guozhangwang Jun 11, 2019
cb2c4c3
MINOR: Remove integration package prefix from ConsumerTopicCreationTe…
gardnervickers Jun 12, 2019
388889f
KAFKA-8514: Move the scala-java8-compat dependency from clients to co…
agavra Jun 12, 2019
e2c15e0
MINOR: Remove uncommitted code (#6919)
highluck Jun 12, 2019
e981b82
KAFKA-8500; Static member rejoin should always update member.id (#6899)
Jun 12, 2019
1cc0b5e
MINOR: Seal the HostedPartition enumeration (#6917)
jsancio Jun 12, 2019
af28010
KAFKA-8483/KAFKA-8484; Ensure safe handling of producerId resets (#6883)
hachikuji Jun 12, 2019
df9ea61
KAFKA-8262, KAFKA-8263: Fix flaky test `MetricsIntegrationTest` (#6922)
cadonna Jun 12, 2019
f396372
MINOR: add group coordinator test coverage (#6926)
Jun 12, 2019
e54ab29
KAFKA-8452: Compressed BufferValue (#6848)
vvcephei Jun 13, 2019
48b65ac
MINOR: Refactor `MetricsIntegrationTest` (#6930)
cadonna Jun 13, 2019
9e60f4c
MINOR: Add system tests README link from main README (#6939)
stanislavkozlovski Jun 14, 2019
8dd4fb5
KAFKA-8530; Check for topic authorization errors in OffsetFetch respo…
hachikuji Jun 14, 2019
3581429
KAFKA-8488: Reduce logging-related string allocation in FetchSessionH…
wenhoujx Jun 14, 2019
2ef02f1
KAFKA-8179: Part I, Bump up consumer protocol to v2 (#6528)
guozhangwang Jun 14, 2019
e047864
MINOR: fix some warnings in the broker
cmccabe Jun 16, 2019
c758122
MINOR: Fix expected output in Streams quickstart
vahidhashemian Jun 16, 2019
57baa40
KAFKA-8457; Move `Log' reference from `Replica` into `Partition` (#6841)
soondenana Jun 17, 2019
1b9e107
KAFKA-7853: Refactor coordinator config (#6854)
Jun 17, 2019
47f908f
KAFKA-8539; Add group.instance.id to Subscription (#6936)
Jun 17, 2019
1ae9291
HOTFIX: Fix optional import in ConsumerCoordinator (#6953)
Jun 17, 2019
52cd59b
MINOR: Simplify controller election utilities (#6944)
hachikuji Jun 17, 2019
6d6366c
KAFKA-6958: Overload KTable methods to allow to name operation name u…
fhussonnois Jun 17, 2019
c7db82b
MINOR: rename subscription construction function (#6954)
Jun 18, 2019
c6ddd31
MINOR: Update docs for KIP-415 (#6958)
kkonstantine Jun 18, 2019
33e39de
KAFKA-8448: Cancel PeriodicProducerExpirationCheck when closing a Log…
jolshan Jun 18, 2019
2c9a150
MINOR: fix consumer group failure message typo (#6962)
Jun 18, 2019
93bf965
KAFKA-8559: Allocate ArrayList with correct size in PartitionStates (…
wenhoujx Jun 19, 2019
a7e771c
KAFKA-8452: Compressed BufferValue review follow-up (#6940)
vvcephei Jun 19, 2019
635c213
KAFKA-8564; Fix NPE on deleted partition dir when no segments remain …
mimaison Jun 19, 2019
d40805d
MINOR: Fix Partition::toString method (#6971)
soondenana Jun 20, 2019
03d61eb
KAFKA-8569: integrate warning message under static membership (#6972)
Jun 20, 2019
1233c96
MINOR: Remove legacy kafka.admin.AdminClient (#6947)
ijuma Jun 21, 2019
d7a5e31
KAFKA-8519 Add trogdor action to slow down a network (#6912)
mumrah Jun 21, 2019
5f8b289
KAFKA-8570; Grow buffer to hold down converted records if it was insu…
dhruvilshah3 Jun 21, 2019
f51d7d3
KAFKA-8557: system tests - add support for (optional) interbroker lis…
stan-is-hate Jun 21, 2019
4d1d995
KAFKA-8563: Remove redundant `NetworkSend.sizeDelimit()` method (#6967)
cryptoe Jun 21, 2019
11b25a1
MINOR: Fix DistributedHerderTest after adding reason to maybeLeaveGro…
kkonstantine Jun 21, 2019
3e9d1c1
KAFKA-8106: Skipping ByteBuffer allocation of key / value / headers i…
guozhangwang Jun 21, 2019
11641c7
MINOR: Reflection free implementation of `defaultKerberosRealm` (#6978)
ijuma Jun 22, 2019
5339d2d
KAFKA-7197: Support Scala 2.13 (#5454)
dejan2609 Jun 22, 2019
fc27cbe
KAFKA-8545: Remove legacy ZkUtils (#6948)
ijuma Jun 23, 2019
7cb0a1e
MINOR: Reinstate info-level log for dynamic update of SSL keystores (…
rajinisivaram Jun 23, 2019
e5c4ebd
KAFKA-8179: Part 2, ConsumerCoordinator Algorithm (#6778)
guozhangwang Jun 23, 2019
a03b503
HOTFIX: removed extra footnote (#6996)
ableegoldman Jun 25, 2019
55707ad
MINOR: add unit test for Utils.murmur2 (#5926)
natemurthy Jun 25, 2019
14d8549
KAFKA-8390: Use automatic RPC generation in CreateDelegationToken (#6…
mimaison Jun 25, 2019
07f492e
MINOR: Fix flaky test case for compact/delete topics (#6975)
hachikuji Jun 25, 2019
a9bf948
MINOR: Fix for typos in processor-api.html (#6961)
seprokof Jun 25, 2019
5216839
Minor: code enhancment (#6999)
khaireddine120 Jun 25, 2019
cfea953
MINOR: Fix typos in upgrade guide (#7005)
ableegoldman Jun 27, 2019
594d043
MINOR: Fix failing upgrade test by supporting both security.inter.bro…
stan-is-hate Jun 27, 2019
357aede
MINOR: Support listener config overrides in system tests (#6981)
brianbushree Jun 27, 2019
fbf6a76
KAFKA-8356: add static membership info to round robin assignor (#6815)
Jun 28, 2019
f8db022
KAFKA-8538 (part of KIP-345): add group.instance.id to DescribeGroup …
Jun 28, 2019
3d2d87a
MINOR: Add compatibility tests for 2.3.0 (#6995)
cmccabe Jun 28, 2019
f74cedb
MINOR: add upgrade text (#7013)
cmccabe Jun 28, 2019
b4e2049
remove cs (#6950)
Jun 28, 2019
53b837f
KAFKA-8542; Cache transaction first offset metadata on follower (#6943)
hachikuji Jun 29, 2019
da07985
MINOR: Assert ExecutionException details in testCreatePartitions (#7017)
ijuma Jul 1, 2019
6dd4ebc
MINOR: Make the build compile with Scala 2.13 (#6989)
ijuma Jul 2, 2019
711c817
KAFKA-8560; The Kafka protocol generator should support common struct…
cmccabe Jul 2, 2019
6f91096
MINOR: Fix version for ConnectDistributed system test, remove 0.9.0.1…
rhauch Jul 2, 2019
ea6cf41
MINOR: Preserve the assignment order from the LeaderAndIsr request (#…
jsancio Jul 3, 2019
298a9bc
MINOR: Adjust Streams parameter hint on TimeoutException (#6280)
ijuma Jul 3, 2019
b0935e5
MINOR: Embedded connect cluster should mask exit procedures by defaul…
hachikuji Jul 3, 2019
5287036
MINOR: system tests - avoid 'sasl.enabled.mechanisms' in listener ove…
brianbushree Jul 3, 2019
5e5dbbd
MINOR: Typo correction in server.properties (#7011)
rajexp Jul 3, 2019
3750898
MINOR: Improve group metadata unknown key version exception message (…
kamalcph Jul 3, 2019
11337af
MINOR: Fix static membership documentation link in upgrade notes (#7001)
kamalcph Jul 3, 2019
0b40d27
MINOR: Remove redundant placeholder in log message (#7016)
pan3793 Jul 3, 2019
07a154e
MINOR: Streams tutorial refers to code in the wrong directory (#7012)
Jul 3, 2019
822abe4
MINOR: WorkerUtils#topicDescriptions must unwrap exceptions properly …
cmccabe Jul 3, 2019
442d362
MINOR: add useConfiguredPartitioner and skipFlush options for Produce…
jolshan Jul 4, 2019
41e1c13
MINOR: Fix a wrong description in PipeDemo's javadoc (#6901)
sekikn Jul 4, 2019
23beeea
KAFKA-8443; Broker support for fetch from followers (#6832)
mumrah Jul 4, 2019
2b529d1
MINOR: Control plane listener tests should not use static port (#7033)
hachikuji Jul 4, 2019
57903be
MINOR: Remove zkclient dependency (#7036)
ijuma Jul 5, 2019
102490e
MINOR: improve RocksDBConfigSetter docs (#7009)
ableegoldman Jul 8, 2019
05cba28
MINOR: A few cleanups and compiler warning fixes (#6986)
dongjinleekr Jul 8, 2019
289ac09
KAFKA-8591; WorkerConfigTransformer NPE on connector configuration re…
nachomdo Jul 9, 2019
3bb126d
MINOR: Fixes AK config typos (#7046)
joel-hamill Jul 9, 2019
9973758
KAFKA-3333: Adds RoundRobinPartitioner with tests (#6771)
mmanna-sapfgl Jul 9, 2019
38f86d1
MINOR: Use `Topic::isInternalTopic` instead of directly checking (#7047)
soondenana Jul 10, 2019
65b044b
KAFKA-8636; Add documentation change for max poll interval with stati…
Jul 10, 2019
df6efda
MINOR: Only invoke hw update logic for follower fetches (#7064)
hachikuji Jul 10, 2019
d67495d
KAFKA-8634: Update ZooKeeper to 3.5.5 (#6802)
ijuma Jul 10, 2019
4f5a5eb
KAFKA-8424: replace ListGroups request/response with automated protoc…
Jul 10, 2019
ebb80f5
KAFKA-8653; Default rebalance timeout to session timeout for JoinGrou…
hachikuji Jul 11, 2019
d70fe5e
KAFKA-8644; The Kafka protocol generator should allow null defaults f…
cmccabe Jul 11, 2019
7a7d4cb
MINOR: Refactor high watermark access and validation (#7055)
hachikuji Jul 11, 2019
25f4e3c
KAFKA-8643; Bring back public MemberDescription constructor (#7060)
Jul 12, 2019
53b4ce5
KAFKA-5998: fix checkpointableOffsets handling (#7030)
vvcephei Jul 12, 2019
8cabd44
Fixes #8198 KStreams testing docs use non-existent method pipe (#6678)
ouertani Jul 12, 2019
fc4fea6
KAFKA-6605: Fix NPE in Flatten when optional Struct is null (#5705)
mihbor Jul 12, 2019
fa042bc
KAFKA-7157: Fix handling of nulls in TimestampConverter (#7070)
rayokota Jul 12, 2019
ae4a975
MINOR: Create a new topic for each test for flaky RegexSourceIntegrat…
bbejeck Jul 12, 2019
d2328a1
HOT FIX: close RocksDB objects in correct order (#7076)
ableegoldman Jul 12, 2019
1d873a9
MINOR: Use dynamic port in `RestServerTest` (#7079)
hachikuji Jul 12, 2019
ea814d7
KAFKA-8614; Consistent naming for IncrementalAlterConfig and AlterCon…
bob-barrett Jul 13, 2019
1f2d230
MINOR: Refactor admin client helpers for checking leader and ISR (#7074)
jsancio Jul 13, 2019
528e5c0
KAFKA-8602: Fix bug in stand-by task creation (#7008)
cadonna Jul 15, 2019
3e48bdb
KAFKA-8620: fix NPE due to race condition during shutdown while rebal…
Jul 15, 2019
8cefe97
KAFKA-8637: WriteBatch objects leak off-heap memory (#7050)
ableegoldman Jul 15, 2019
d227f94
KAFKA-8662; Fix producer metadata error handling and consumer manual …
rajinisivaram Jul 16, 2019
00757cd
KAFKA-8450: Using KeyValueTimeStamp in MockProcessor (#6933)
suryateja008 Jul 16, 2019
f65c71c
MINOR: Increase `awaitCommits` timeout in ExampleConnectIntegrationTe…
hachikuji Jul 16, 2019
ecf23b5
KAFKA-8024; Fix `UtilsTest` failure under non-english locales (#6351)
pkleindl Jul 17, 2019
53b10a3
MINOR: Fix api exception single argument constructor usage (#6956)
hachikuji Jul 17, 2019
f899489
MINOR: improve error message for incorrect window-serde initializati…
mjsax Jul 17, 2019
ab8a7ff
KAFKA-8670; Fix exception for kafka-topics.sh --describe without --to…
Jul 18, 2019
62fbc92
KAFKA-8615: Change to track partition time breaks TimestampExtractor …
ableegoldman Jul 18, 2019
2e26a46
KAFKA-8635; Skip client poll in Sender loop when no request is sent (…
bob-barrett Jul 18, 2019
9829c72
MINOR: Remove stale streams producer retry default docs. (#6844)
cwildman Jul 19, 2019
d054875
MINOR: Update documentation for enabling optimizations (#7099)
bbejeck Jul 19, 2019
58938a0
KAFKA-8513: Add kafka-streams-application-reset.bat for Windows platf…
sekikn Jul 19, 2019
aa8e850
KAFKA-8392: Fix old metrics leakage by brokers that have no leadershi…
tuvtran Jul 19, 2019
e3524ef
KAFKA-8435: replace delete groups request/response with automated pro…
Jul 20, 2019
e5f7220
MINOR: kafkatest - adding whitelist for interbroker sasl configs (#7093)
brianbushree Jul 22, 2019
2a133ba
KAFKA-8454; Add Java AdminClient Interface (KIP-476) (#7087)
big-andy-coates Jul 22, 2019
f98e176
KAFKA-8678; Fix leave group protocol bug in throttling and error resp…
Jul 22, 2019
6b6a6b9
KAFKA-8526; Fallback to other log dirs after getOrCreateLog failure (…
soarez Jul 23, 2019
a8aedc8
KAFKA-8696: clean up Sum/Count/Total metrics (#7057)
vvcephei Jul 23, 2019
e9c61f6
MINOR: Ensure in-memory metadata is removed before physical deletion …
dhruvilshah3 Jul 25, 2019
69d86a1
KAFKA-8179: add public ConsumerPartitionAssignor interface (#7108)
ableegoldman Jul 25, 2019
79341a1
KAFKA-8715; Fix buggy reliance on state timestamp in static member.id…
Jul 26, 2019
74c90f4
KAFKA-8221; Add batch leave group request (#6714)
Jul 27, 2019
9ad7bce
MINOR: Close ZKDatabase in EmbeddedZookeeper (#6237)
ArloL Jul 28, 2019
acf507c
MINOR: Remove unused TopicAndPartition and remove unused symbols (#7119)
ijuma Jul 28, 2019
39bcc84
MINOR: Fix Streams metadata upgrade system test (#7118)
mjsax Jul 29, 2019
81900d0
KAFKA-8345: KIP-455 Protocol changes (part 1) (#7114)
stanislavkozlovski Jul 29, 2019
2047108
KAFKA-8640; Use generated classes in OffsetFetch request and response…
Jul 30, 2019
c6286b2
KAFKA-8442; Include ISR in Metadata response even if there is no lead…
huxi-2b Jul 30, 2019
a48b5d9
KAFKA-8717; Reuse cached offset metadata when reading from log (#7081)
hachikuji Jul 30, 2019
73ed9ea
MINOR: Refactor abstractConfig#configuredInstance (#7129)
guozhangwang Jul 30, 2019
de8ce78
MINOR: Tolerate limited data loss for upgrade tests with old message …
rajinisivaram Jul 31, 2019
211745d
MINOR: Small cleanups in TopicCommand describe handling (#7136)
hachikuji Jul 31, 2019
cdea348
Update KafkaConfig.scala (#7113)
gemma-singleton Jul 31, 2019
6fbac3c
KAFKA-8179: PartitionAssignorAdapter (#7110)
ableegoldman Jul 31, 2019
2c2b30d
MINOR: Add RandomComponentPayloadGenerator and update Trogdor documen…
jolshan Jul 31, 2019
a028f59
KAFKA-8731: InMemorySessionStore throws NullPointerException on start…
ableegoldman Jul 31, 2019
06e246d
KAFKA-8456: Stabilize flaky StoreUpgradeIntegrationTest (#6941)
mjsax Aug 1, 2019
d997dc6
MINOR: Fix wrong debug log message (#7137)
cadonna Aug 1, 2019
717c55b
KAFKA-8601: Implement KIP-480: Sticky Partitioning for keyless record…
jolshan Aug 1, 2019
1546fc3
KAFKA-7548; KafkaConsumer should not discard fetched data for paused …
seglo Aug 2, 2019
22d4ccd
MINOR: Update docs to reflect the ZK 3.5.5 upgrade (#7149)
ijuma Aug 2, 2019
a7d0fdd
KAFKA-8578: Add basic functionality to expose RocksDB metrics (#6979)
cadonna Aug 2, 2019
a99e011
KAFKA-7800; Dynamic log levels admin API (KIP-412)
stanislavkozlovski Aug 2, 2019
96c575a
MINOR: Fix binary compatibility break in KafkaClientSupplier.getAdmin…
ijuma Aug 3, 2019
c76f565
MINOR: Fix typo in docs (#7158)
londoncalling Aug 3, 2019
320f7b0
MINOR: Avoid dividing by zero (#7143)
mjsax Aug 3, 2019
0b1dc1c
KAFKA-6263; Expose metrics for group and transaction metadata loading…
anatasiavela Aug 4, 2019
f70ece2
MINOR: Fix potential bug in LogConfig.getConfigValue and improve test…
ijuma Aug 4, 2019
7663a6c
Minor: Refactor methods to add metrics to sensor in `StreamsMetricsIm…
cadonna Aug 6, 2019
7ebcd50
KAFKA-8736: Streams performance improvement, use isEmpty() rather tha…
mjarvie Aug 6, 2019
e4e2dd3
MINOR: some small style fixes to RoundRobinPartitioner
cmccabe Aug 6, 2019
97b731b
MINOR: Upgrade jackson-databind to 2.9.9.3 (#7125)
ijuma Aug 7, 2019
926fb35
KAFKA-8599: Use automatic RPC generation in ExpireDelegationToken
mimaison Aug 7, 2019
66d81a0
MINOR: Update dependencies for Kafka 2.4 (#7126)
ijuma Aug 8, 2019
e867a58
KAFKA-8179: Part 3, Add PartitionsLost API for resetGenerations and m…
guozhangwang Aug 8, 2019
5e543ae
KAFKA-8598: Use automatic RPC generation in RenewDelegationToken
mimaison Aug 9, 2019
600cc48
KAFKA-8748: Fix flaky testDescribeLogDirsRequest (#7182)
ijuma Aug 9, 2019
3f00649
MINOR: Ignore dynamic log4j log level tests (#7183)
stanislavkozlovski Aug 9, 2019
e9a35fe
MINOR: Bump system test version from 2.2.0 to 2.2.1 (#6873)
mjsax Aug 9, 2019
7511ccf
KAFKA-8550: Fix plugin loading of aliased converters in Connect (#6959)
C0urante Aug 11, 2019
35ed7b1
MINOR: Eliminate unnecessary map operations in RecordAccumulator.isMu…
lbradstreet Aug 11, 2019
558bb1d
KAFKA-8782: Close metrics in QuotaManagerTests (#7191)
ijuma Aug 11, 2019
4148d79
MINOR: Remove Utils.notNull, use Objects.requireNonNull instead (#7194)
ijuma Aug 12, 2019
0c2d1c3
MINOR: Format AdminUtils::assignReplicasToBrokers java documentation …
soondenana Aug 12, 2019
88087e9
MINOR: Clean up the sticky partitioner code a bit (#7151)
jolshan Aug 12, 2019
7946372
KAFKA-8774: Regex can be found anywhere in config value (#7197)
wicknicks Aug 13, 2019
e2c8612
KAFKA-7941: Catch TimeoutException in KafkaBasedLog worker thread (#6…
pgwhalen Aug 13, 2019
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
6 changes: 6 additions & 0 deletions .gitignore
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
dist
*classes
*.class
target/
build/
build_eclipse/
Expand Down Expand Up @@ -47,3 +48,8 @@ tests/venv
docs/generated/

.release-settings.json

kafkatest.egg-info/
systest/
*.swp
clients/src/generated
2 changes: 1 addition & 1 deletion CONTRIBUTING.md
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
## Contributing to Kafka

*Before opening a pull request*, review the [Contributing](http://kafka.apache.org/contributing.html) and [Contributing Code Changes](https://cwiki.apache.org/confluence/display/KAFKA/Contributing+Code+Changes) pages.
*Before opening a pull request*, review the [Contributing](https://kafka.apache.org/contributing.html) and [Contributing Code Changes](https://cwiki.apache.org/confluence/display/KAFKA/Contributing+Code+Changes) pages.

It lists steps that are required before creating a PR.

Expand Down
66 changes: 66 additions & 0 deletions LICENSE
Original file line number Diff line number Diff line change
Expand Up @@ -201,6 +201,7 @@
See the License for the specific language governing permissions and
limitations under the License.

------------------------------------------------------------------------------------
This distribution has a binary dependency on jersey, which is available under the CDDL
License as described below.

Expand Down Expand Up @@ -328,3 +329,68 @@ As between Initial Developer and the Contributors, each party is responsible for
NOTICE PURSUANT TO SECTION 9 OF THE COMMON DEVELOPMENT AND DISTRIBUTION LICENSE (CDDL)

The code released under the CDDL shall be governed by the laws of the State of California (excluding conflict-of-law provisions). Any litigation relating to this License shall be subject to the jurisdiction of the Federal Courts of the Northern District of California and the state courts of the State of California, with venue lying in Santa Clara County, California.

------------------------------------------------------------------------------------
This distribution has a binary dependency on zstd, which is available under the BSD 3-Clause License as described below.

BSD License

For Zstandard software

Copyright (c) 2016-present, Facebook, Inc. All rights reserved.

Redistribution and use in source and binary forms, with or without modification,
are permitted provided that the following conditions are met:

* Redistributions of source code must retain the above copyright notice, this
list of conditions and the following disclaimer.

* Redistributions in binary form must reproduce the above copyright notice,
this list of conditions and the following disclaimer in the documentation
and/or other materials provided with the distribution.

* Neither the name Facebook nor the names of its contributors may be used to
endorse or promote products derived from this software without specific
prior written permission.

THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR
ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
(INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

------------------------------------------------------------------------------------
This distribution has a binary dependency on zstd-jni, which is available under the BSD 2-Clause License
as described below.

Zstd-jni: JNI bindings to Zstd Library

Copyright (c) 2015-2016, Luben Karavelov/ All rights reserved.

BSD License

Redistribution and use in source and binary forms, with or without modification,
are permitted provided that the following conditions are met:

* Redistributions of source code must retain the above copyright notice, this
list of conditions and the following disclaimer.

* Redistributions in binary form must reproduce the above copyright notice, this
list of conditions and the following disclaimer in the documentation and/or
other materials provided with the distribution.

THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR
ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
(INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
4 changes: 2 additions & 2 deletions NOTICE
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
Apache Kafka
Copyright 2017 The Apache Software Foundation.
Copyright 2019 The Apache Software Foundation.

This product includes software developed at
The Apache Software Foundation (http://www.apache.org/).
The Apache Software Foundation (https://www.apache.org/).

This distribution has a binary dependency on jersey, which is available under the CDDL
License. The source code of jersey can be found at https://github.com/jersey/jersey/.
72 changes: 37 additions & 35 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,12 +1,14 @@
Apache Kafka
=================
See our [web site](http://kafka.apache.org) for details on the project.
See our [web site](https://kafka.apache.org) for details on the project.

You need to have [Gradle](http://www.gradle.org/installation) and [Java](http://www.oracle.com/technetwork/java/javase/downloads/index.html) installed.
You need to have [Gradle](https://www.gradle.org/installation) and [Java](https://www.oracle.com/technetwork/java/javase/downloads/index.html) installed.

Kafka requires Gradle 3.0 or higher.
Kafka requires Gradle 5.0 or higher.

Java 7 should be used for building in order to support both Java 7 and Java 8 at runtime.
Java 8 should be used for building in order to support both Java 8 and Java 11 at runtime.

Scala 2.12 is used by default, see below for how to use a different Scala version or all of the supported Scala versions.

### First bootstrap and download the wrapper ###
cd kafka_source_dir
Expand All @@ -17,7 +19,7 @@ Now everything else will work.
### Build a jar and run it ###
./gradlew jar

Follow instructions in http://kafka.apache.org/documentation.html#quickstart
Follow instructions in https://kafka.apache.org/documentation.html#quickstart

### Build source jar ###
./gradlew srcJar
Expand All @@ -43,7 +45,7 @@ Follow instructions in http://kafka.apache.org/documentation.html#quickstart
./gradlew cleanTest integrationTest

### Running a particular unit/integration test ###
./gradlew -Dtest.single=RequestResponseSerializationTest core:test
./gradlew clients:test --tests RequestResponseTest

### Running a particular test method within a unit/integration test ###
./gradlew core:test --tests kafka.api.ProducerFailureHandlingTest.testCannotSendToInternalTopic
Expand All @@ -52,7 +54,7 @@ Follow instructions in http://kafka.apache.org/documentation.html#quickstart
### Running a particular unit/integration test with log4j output ###
Change the log4j setting in either `clients/src/test/resources/log4j.properties` or `core/src/test/resources/log4j.properties`

./gradlew -i -Dtest.single=RequestResponseSerializationTest core:test
./gradlew clients:test --tests RequestResponseTest

### Generating test coverage reports ###
Generate coverage reports for the whole project:
Expand All @@ -64,28 +66,33 @@ Generate coverage for a single module, i.e.:
./gradlew clients:reportCoverage

### Building a binary release gzipped tar ball ###
./gradlew clean
./gradlew releaseTarGz
./gradlew clean releaseTarGz

The above command will fail if you haven't set up the signing key. To bypass signing the artifact, you can run:

./gradlew releaseTarGz -x signArchives
./gradlew clean releaseTarGz -x signArchives

The release file can be found inside `./core/build/distributions/`.

### Cleaning the build ###
./gradlew clean

### Running a task on a particular version of Scala (either 2.11.x or 2.12.x) ###
*Note that if building the jars with a version other than 2.11.12, you need to set the `SCALA_VERSION` variable or change it in `bin/kafka-run-class.sh` to run the quick start.*
### Running a task with one of the Scala versions available (2.11.x, 2.12.x or 2.13.x) ###
*Note that if building the jars with a version other than 2.12.x, you need to set the `SCALA_VERSION` variable or change it in `bin/kafka-run-class.sh` to run the quick start.*

You can pass either the major version (eg 2.12) or the full version (eg 2.12.7):

./gradlew -PscalaVersion=2.12 jar
./gradlew -PscalaVersion=2.12 test
./gradlew -PscalaVersion=2.12 releaseTarGz

You can pass either the major version (eg 2.11) or the full version (eg 2.11.12):
### Running a task with all the scala versions enabled by default ###

./gradlew -PscalaVersion=2.11 jar
./gradlew -PscalaVersion=2.11 test
./gradlew -PscalaVersion=2.11 releaseTarGz
Append `All` to the task name:

Scala 2.12.x requires Java 8.
./gradlew testAll
./gradlew jarAll
./gradlew releaseTarGzAll

### Running a task for a specific project ###
This is for `core`, `examples` and `clients`
Expand All @@ -106,15 +113,6 @@ The `eclipse` task has been configured to use `${project_dir}/build_eclipse` as
build directory (`${project_dir}/bin`) clashes with Kafka's scripts directory and we don't use Gradle's build directory
to avoid known issues with this configuration.

### Building the jar for all scala versions and for all projects ###
./gradlew jarAll

### Running unit/integration tests for all scala versions and for all projects ###
./gradlew testAll

### Building a binary release gzipped tar ball for all scala versions ###
./gradlew releaseTarGzAll

### Publishing the jar for all version of Scala and for all projects to maven ###
./gradlew uploadArchivesAll

Expand Down Expand Up @@ -170,7 +168,7 @@ Please note for this to work you should create/update user maven settings (typic
./gradlew dependencyUpdates

### Running code quality checks ###
There are two code quality analysis tools that we regularly run, findbugs and checkstyle.
There are two code quality analysis tools that we regularly run, spotbugs and checkstyle.

#### Checkstyle ####
Checkstyle enforces a consistent coding style in Kafka.
Expand All @@ -181,14 +179,14 @@ You can run checkstyle using:
The checkstyle warnings will be found in `reports/checkstyle/reports/main.html` and `reports/checkstyle/reports/test.html` files in the
subproject build directories. They are also are printed to the console. The build will fail if Checkstyle fails.

#### Findbugs ####
Findbugs uses static analysis to look for bugs in the code.
You can run findbugs using:
#### Spotbugs ####
Spotbugs uses static analysis to look for bugs in the code.
You can run spotbugs using:

./gradlew findbugsMain findbugsTest -x test
./gradlew spotbugsMain spotbugsTest -x test

The findbugs warnings will be found in `reports/findbugs/main.html` and `reports/findbugs/test.html` files in the subproject build
directories. Use -PxmlFindBugsReport=true to generate an XML report instead of an HTML one.
The spotbugs warnings will be found in `reports/spotbugs/main.html` and `reports/spotbugs/test.html` files in the subproject build
directories. Use -PxmlSpotBugsReport=true to generate an XML report instead of an HTML one.

### Common build options ###

Expand All @@ -200,7 +198,11 @@ The following options should be set with a `-P` switch, for example `./gradlew -
* `showStandardStreams`: shows standard out and standard error of the test JVM(s) on the console.
* `skipSigning`: skips signing of artifacts.
* `testLoggingEvents`: unit test events to be logged, separated by comma. For example `./gradlew -PtestLoggingEvents=started,passed,skipped,failed test`.
* `xmlFindBugsReport`: enable XML reports for findBugs. This also disables HTML reports as only one can be enabled at a time.
* `xmlSpotBugsReport`: enable XML reports for spotBugs. This also disables HTML reports as only one can be enabled at a time.

### Running system tests ###

See [tests/README.md](tests/README.md).

### Running in Vagrant ###

Expand All @@ -211,4 +213,4 @@ See [vagrant/README.md](vagrant/README.md).
Apache Kafka is interested in building the community; we would welcome any thoughts or [patches](https://issues.apache.org/jira/browse/KAFKA). You can reach us [on the Apache mailing lists](http://kafka.apache.org/contact.html).

To contribute follow the instructions here:
* http://kafka.apache.org/contributing.html
* https://kafka.apache.org/contributing.html
Loading