let kafka support "commit offset after consuming"#206

Closed

wyzssw wants to merge 491 commits into

0.8.2from

This pull request is big! We're only showing the most recent 250 commits

Commits on May 12, 2015

KAFKA-1660; Add API to the producer to support close with a timeout; reviewed by Joel Koshy and Jay Kreps.

becketqin
authored and
jjkoshy
committed

Commits on May 14, 2015

KAFKA-1334; Add the heartbeat logic to consumer coordinator; reviewed by Guozhang Wang

onurkaraman
authored and
guozhangwang
committed

Commits on May 18, 2015

kafka-2169; Upgrade to zkclient-0.5; patched by Parth Brahmbhatt; reviewed by Jun Rao

Parth Brahmbhatt
authored and
junrao
committed

Commits on May 20, 2015

Commits on May 21, 2015

Commits on May 24, 2015

KAFKA-1737; Enforce ZKSerializer while creating ZkClient; reviewed by Guozhang Wang

vivekpm
authored and
guozhangwang
committed

Commits on May 28, 2015

kafka-2189; Snappy compression of message batches less efficient in 0.8.2.1; patched by Ismael Juma; reviewed by Jun Rao

ijuma
authored and
junrao
committed
KAFKA-2186; Follow-up to KAFKA-1650 - add selective offset commit to consumer connector API; reviewed by Joel Koshy

becketqin
authored and
jjkoshy
committed
KAFKA-2091; Expose a partitioner interface in the new producer

Sriharsha Chintalapani
authored and
jjkoshy
committed

Commits on May 29, 2015

kafka-2185; Update to Gradle 2.4; patched by Ismael Juma; reviewed by Jun Rao

ijuma
authored and
junrao
committed
KAFKA-2199 Make signing artifacts optional and disabled by

ewencp
authored and
jkreps
committed

Commits on Jun 1, 2015

kafka-2226; NullPointerException in TestPurgatoryPerformance; patched by Yasuhiro Matsuda; reviewed by Onur Karaman, Guozhang Wang and Jun Rao

ymatsuda
authored and
junrao
committed

Commits on Jun 3, 2015

Commits on Jun 4, 2015

kafka-1928; Move kafka.network over to using the network classes in org.apache.kafka.common.network; patched by Gwen Shapira; reviewed by Joel Koshy, Jay Kreps, Jiangjie Qin, Guozhang Wang and Jun Rao

gwenshap
authored and
junrao
committed

Commits on Jun 5, 2015

KAFKA-2246; UnknownTopicOrPartitionException should be an instance of InvalidMetadataException; reviewed by Ewen Cheslack-Postava and Joel Koshy

becketqin
authored and
jjkoshy
committed

Commits on Jun 10, 2015

KAFKA-2253; fix deadlock between removeWatchersLock and watcher operations list lock; reviewed by Onur Karaman and Jiangjie Qin
guozhangwang
committed

Commits on Jun 11, 2015

kafka-2005; Generate html report for system tests; patched by Ashish Singh; reviewed by Jun Rao

Ashish Singh
authored and
junrao
committed

Commits on Jun 12, 2015

kafka-2266; Client Selector can drop idle connections without notifying NetworkClient; patched by Jason Gustafson; reviewed by Jun Rao

Jason Gustafson
authored and
junrao
committed
kafka-2232; make MockProducer generic; patched by Alexander Pakulov; reviewed by Jun Rao

apakulov
authored and
junrao
committed

Commits on Jun 13, 2015

kafka-2164; ReplicaFetcherThread: suspicious log message on reset offset; patched by Alexey Ozeritski; reviewed by Jun Rao

resetius
authored and
junrao
committed

Commits on Jun 16, 2015

Commits on Jun 18, 2015

Commits on Jun 19, 2015

Commits on Jun 22, 2015

kafka-2290; OffsetIndex should open RandomAccessFile consistently; patched by Chris Black; reviewed by Jun Rao

Chris Black
authored and
junrao
committed
kafka-2235; LogCleaner offset map overflow; patched by Ivan Simoneko; reviewed by Jun Rao

isimonenko
authored and
junrao
committed
KAFKA-2245; Add response tests for consumer coordinator; reviewed by Joel Koshy

onurkaraman
authored and
jjkoshy
committed
KAFKA-2293; Fix incorrect format specification in Partition.scala; reviewed by Joel Koshy

auradkar
authored and
jjkoshy
committed

Commits on Jun 23, 2015

Commits on Jun 30, 2015

KAFKA-2281: avoid unnecessary value copying if logAsString is false; reviewed by Guozhang Wang

xiaotao183
authored and
guozhangwang
committed

Commits on Jul 1, 2015

KAFKA-2168: minor follow-up patch; reviewed by Guozhang Wang

hachikuji
authored and
guozhangwang
committed

Commits on Jul 2, 2015

KAFKA-1740: merge offset manager into consumer coordinator; reviewed by Onur Karaman and Jason Gustafson
guozhangwang
committed

Commits on Jul 6, 2015

Commits on Jul 7, 2015

KAFKA-2314: proper MirrorMaker's message handler help message; reviewed by Guozhang Wang

lazyval
authored and
guozhangwang
committed
kafka-1367; Broker topic metadata not kept in sync with ZooKeeper; patched by Ashish Singh; reviewed by Jun Rao

Ashish Singh
authored and
junrao
committed
KAFKA-2304 Supported enabling JMX in Kafka Vagrantfile patch by Stevo Slavic reviewed by Ewen Cheslack-Postava
joestein
committed
KAFKA-2306: add another metric for buffer exhausted; reviewed by Guozhang Wang

lindong28
authored and
guozhangwang
committed
KAFKA-2317: follow-up of KAFKA1367; reviewed by Guozhang Wang

Ashish Singh
authored and
guozhangwang
committed
KAFKA-2313: javadoc fix for KafkaConsumer deserialization; reviewed by Guozhang Wang

onurkaraman
authored and
guozhangwang
committed

Commits on Jul 8, 2015

KAFKA-2298; Client Selector can drop connections on InvalidReceiveException without notifying NetworkClient; reviewed by Jason Gustafson and Joel Koshy

lindong28
authored and
jjkoshy
committed
Trivial commit - explicitly exclude build/rat-report.xml from rat check
jjkoshy
committed
KAFKA-2308: make MemoryRecords idempotent; reviewed by Guozhang Wang

gwenshap
authored and
guozhangwang
committed
KAFKA-2316: Drop java 1.6 support; patched by Sriharsha Chintalapani reviewed by Ismael Juma and Gwen Shapira

Sriharsha Chintalapani
authored and
gwenshap
committed

Commits on Jul 9, 2015

KAFKA-2327; broker doesn't start if config defines advertised.host but not advertised.port

Geoff Anderson
authored and
gwenshap
committed

Commits on Jul 10, 2015

Commits on Jul 13, 2015

KAFKA-2312: use atomic long for thread id reference; reviewed by Ewen Cheslack-Postava, Jason Gustafson, Ismael Juma and Guozhang Wang

Tim-Brooks
authored and
guozhangwang
committed

Commits on Jul 14, 2015

kafka-972; MetadataRequest returns stale list of brokers; patched by Ashish Singh; reviewed by Jun Rao

Ashish Singh
authored and
junrao
committed
KAFKA-2198: kafka-topics.sh exits with 0 status on failures; patched by Manikumar Reddy reviewed by Gwen Shapira

omkreddy
authored and
gwenshap
committed

Commits on Jul 15, 2015

Commits on Jul 16, 2015

[MINOR] fix new consumer heartbeat reschedule bug

hachikuji
authored and
guozhangwang
committed
KAFKA-2032: validate consumer's partition-assignment config; reviewed by Jason Rosenberg, Sriharsha Chintalapani and Guozhang Wang

Parth Brahmbhatt
authored and
guozhangwang
committed
kafka-2323; Simplify ScalaTest dependency versions; patched by Ismael Juma; reviewed by Jun Rao

ijuma
authored and
junrao
committed
kafka-2241; AbstractFetcherThread.shutdown() should not block on ReadableByteChannel.read(buffer); patched by Dong Lin; reviewed by Jun Rao

lindong28
authored and
junrao
committed

Commits on Jul 17, 2015

kafka-2174; Wrong TopicMetadata deserialization; patched by Alexey Ozeritskiy; reviewed by Jun Rao

resetius
authored and
junrao
committed
kafka-2271; transient unit test failure in KafkaConfigConfigDefTest.testFromPropsToProps; patched by Jason Gustafson; reviewed by Jun Rao

Jason Gustafson
authored and
junrao
committed
kafka-2103; kafka.producer.AsyncProducerTest failure; patched by Ewen Cheslack-Postava; reviewed by Jun Rao

ewencp
authored and
junrao
committed
KAFKA-2324; Update to Scala 2.11.7

ijuma
authored and
gwenshap
committed
KAFKA-2345; Attempt to delete a topic already marked for deletion throws ZkNodeExistsException; patched by Ashish Singh; reviewed by Sriharsha Chintalapani and Ismael Juma

Ashish Singh
authored and
gwenshap
committed
Adding a file missed while committing KAFKA-2345
gwenshap
committed

Commits on Jul 20, 2015

Commits on Jul 22, 2015

KAFKA-2342; KafkaConsumer rebalance with in-flight fetch can cause invalid position

hachikuji
authored and
guozhangwang
committed

Commits on Jul 23, 2015

Commits on Jul 24, 2015

Commits on Jul 27, 2015

KAFKA-2321; Introduce CONTRIBUTING.md

ijuma
authored and
guozhangwang
committed

Commits on Jul 28, 2015

KAFKA-2301: Warn ConsumerOffsetChecker as deprecated; reviewed by Ewen Cheslack-Postava and Guozhang Wang

Ashish Singh
authored and
guozhangwang
committed
KAFKA-2381: Fix concurrent modification on assigned partition while looping over it; reviewed by Jason Gustafson, Aditya Auradkar, Ewen Cheslack-Postava, Ismael Juma and Guozhang Wang

Ashish Singh
authored and
guozhangwang
committed
KAFKA-2347: Add setConsumerRebalanceListener method to ZookeeperConsumerConnector java api; reviewed by Jiangjie Qin, Ismael Juma, Grant Henke and Guozhang Wang

Ashish Singh
authored and
guozhangwang
committed
KAFKA-2275: Add ListTopics() API to the Java consumer; reviewed by Jason Gustafson, Edward Ribeiro and Guozhang Wang

Ashish Singh
authored and
guozhangwang
committed
KAFKA-2089: Fix transient MetadataTest failure; reviewed by Jiangjie Qin and Guozhang Wang

rajinisivaram
authored and
guozhangwang
committed

Commits on Jul 29, 2015

KAFKA-2276; KIP-25 initial patch

Geoff Anderson
authored and
guozhangwang
committed
KAFKA-2100; Client Error doesn't preserve or display original server error code when it is an unknown code; Reviewed by Gwen, Guozhang and Ewen

dajac
authored and
gwenshap
committed

Commits on Jul 30, 2015

MINOR: Fixed ConsumerRecord constructor javadoc

sslavic
authored and
guozhangwang
committed
KAFKA-2350; KafkaConsumer pause/resume API

hachikuji
authored and
guozhangwang
committed
KAFKA-2026: fix logging of unsued options always showing null; reviewed by Ewen Cheslack-Postava and Jiangjie Qin

omkreddy
authored and
guozhangwang
committed

Commits on Aug 3, 2015

KAFKA-2384: Override commit message title in kafka-merge-pr.py

ijuma
authored and
guozhangwang
committed
MINOR: Added to .gitignore Kafka server logs directory

sslavic
authored and
Chen Shapira
committed
KAFKA-2386; increase timeouts for transient test failure in ConsumerCoordinatorResponseTests

hachikuji
authored and
Chen Shapira
committed

Commits on Aug 4, 2015

Commits on Aug 5, 2015

KAFKA-2405; Don't kill the JVM on session establishment failure

jaikiran
authored and
Chen Shapira
committed
KAFKA-2288; Follow-up to KAFKA-2249 - reduce logging and testing; Reviewd by Jun Rao
gwenshap
committed
KAFKA-2407: Only create log directory when it will be used

granthenke
authored and
gwenshap
committed
KAFKA-2401: Fix transient failure in ProducerSendTest.testCloseWithZeroTimeoutFromSenderThread

becketqin
authored and
guozhangwang
committed
KAFKA-2393: Correctly Handle InvalidTopicException in KafkaApis.getTo…

granthenke
authored and
junrao
committed
MINOR: ConsumerRecords are organized per topic partition

sslavic
authored and
guozhangwang
committed
MINOR: auto.offset.reset docs not in sync with validation

sslavic
authored and
guozhangwang
committed
MINOR: Fixed javadoc for committed return value

sslavic
authored and
guozhangwang
committed
MINOR: Fix typo in ReplicaVerificationTool output

ottomata
authored and
guozhangwang
committed

Commits on Aug 6, 2015

KAFKA-2400: Expose heartbeat interval in KafkaConsumer configuration

hachikuji
authored and
guozhangwang
committed
KAFKA-2340: Improve KafkaConsumer Fetcher test coverage

hachikuji
authored and
guozhangwang
committed

Commits on Aug 7, 2015

KAFKA-2413; New consumer's subscribe(Topic...) api fails if called more than once

onurkaraman
authored and
gwenshap
committed
Minor: Fixes to Selector's javadoc

ijuma
authored and
gwenshap
committed
MINOR: documentation fix in StringDecoder

davecromberge
authored and
gwenshap
committed
KAFKA-2415; Fix transient failure in LogRecoveryTest

becketqin
authored and
gwenshap
committed

Commits on Aug 8, 2015

KAFKA-1997: Follow-up patch, hardcode key/value serializer in mirror maker to byte serializer.

becketqin
authored and
guozhangwang
committed

Commits on Aug 11, 2015

KAFKA-2202: fix consumerTimeoutMs computation on ConsumerPerformance; reviewed by Guozhang Wang

omkreddy
authored and
guozhangwang
committed
KAFKA-2336: Changing offsets.topic.num.partitions after the offset topic is created breaks consumer group partition assignment; Reviewed by Jiangjie Qin, Gwen Shapira

granthenke
authored and
gwenshap
committed
KAFKA-2408: ConsoleConsumerService direct log output to file

Geoff Anderson
authored and
guozhangwang
committed

Commits on Aug 12, 2015

KAFKA-2300: Error in controller log when broker tries to rejoin cluster

fpj
authored and
guozhangwang
committed
MINOR: Fix hard coded strings in ProduceResponse

granthenke
authored and
guozhangwang
committed
KAFKA-2429: Add annotations to mark classes as stable/unstable

ewencp
authored and
gwenshap
committed

Commits on Aug 13, 2015

KAFKA-1782: fix JUnit3 Misuse

apakulov
authored and
guozhangwang
committed
KAFKA-2430; Listing of PR commits in commit message should be optional

ijuma
authored and
guozhangwang
committed
KAFKA-2406: Throttle ISR propagation

becketqin
authored and
junrao
committed
MINOR: expose vagrant base box as variable

Geoff Anderson
authored and
guozhangwang
committed

Commits on Aug 14, 2015

KAFKA-2366; Initial patch for Copycat

ewencp
authored and
gwenshap
committed

Commits on Aug 15, 2015

Commits on Aug 17, 2015

KAFKA-2438; add maxParallelForks to build.gradle to speedup tests.

Sriharsha Chintalapani
authored and
gwenshap
committed

Commits on Aug 18, 2015

KAFKA-2436; log.retention.hours should be honored by LogManager

lindong28
authored and
gwenshap
committed

Commits on Aug 19, 2015

Commits on Aug 21, 2015

KAFKA-2457; StackOverflowError during builds

ijuma
authored and
gwenshap
committed
KAFKA-2457; Fix how the argument is passed to `compileScala`

ijuma
authored and
gwenshap
committed

Commits on Aug 23, 2015

KAFKA-2439; Add MirrorMaker service class for system tests

Geoff Anderson
authored and
gwenshap
committed

Commits on Aug 28, 2015

KAFKA-2468: SIGINT during Kafka server startup can leave server deadlocked

Ashish Singh
authored and
guozhangwang
committed
MINOR: kafkatest add manifest

Geoff Anderson
authored and
gwenshap
committed

Commits on Aug 31, 2015

KAFKA-2475: Make Copycat only have a Converter class instead of Serializer, Deserializer, and Converter.

ewencp
authored and
gwenshap
committed
KAFKA-2485; Allow producer performance to take properties from a file…

lindong28
authored and
gwenshap
committed
KAFKA-2486; fix performance regression in new consumer

hachikuji
authored and
gwenshap
committed

Commits on Sep 1, 2015

KAFKA-2332; Add quota metrics to old producer and consumer

lindong28
authored and
jjkoshy
committed

Commits on Sep 2, 2015

TRIVIAL: Replace "it's" with "its" where appropriate

reftel
authored and
gwenshap
committed
KAFKA-2492; Upgraded zkclient dependency from 0.5 to 0.6

sslavic
authored and
gwenshap
committed
TRIVIAL: Updated testing readme

Geoff Anderson
authored and
gwenshap
committed
KAFKA-2411; remove usage of blocking channel

ijuma
authored and
junrao
committed

Commits on Sep 3, 2015

kafka-2210; KafkaAuthorizer: Add all public entities, config changes and changes to KafkaAPI and kafkaServer to allow pluggable authorizer implementation; patched by Parth Brahmbhatt; reviewed Isma…

Parth Brahmbhatt
authored and
junrao
committed
KAFKA-2437; Fix ZookeeperLeaderElector to handle node deletion correctly.

becketqin
authored and
jjkoshy
committed
KAFKA-2437; Trivial follow-up
jjkoshy
committed
KAFKA-2461; request logger no longer logs extra information in debug mode

asingh
authored and
gwenshap
committed
MINOR: Fix trace/debug logs in RequestChannel

Ashish Singh
authored and
gwenshap
committed

Commits on Sep 4, 2015

KAFKA-2519; NetworkClient.close should remove node from inFlightRequests

ijuma
authored and
junrao
committed

Commits on Sep 8, 2015

KAFKA-2453: Enable new consumer in EndToEndLatency

benstopford
authored and
gwenshap
committed
TRIVIAL: change to API doc for seekToEnd() to clarify lazy evaluation

benstopford
authored and
gwenshap
committed

Commits on Sep 9, 2015

KAFKA-2489: add benchmark for new consumer

Geoff Anderson
authored and
gwenshap
committed

Commits on Sep 10, 2015

KAFKA-1893: Allow regex subscriptions in the new consumer

Ashish Singh
authored and
guozhangwang
committed

Commits on Sep 11, 2015

KAFKA-2389: remove commit type from new consumer.

becketqin
authored and
guozhangwang
committed
KAFKA-2278: JmxTool should support querying all objects when object name is omitted

lindong28
authored and
guozhangwang
committed
KAFKA-2440; Use `NetworkClient` instead of `SimpleConsumer` to fetch data from replica

ijuma
authored and
junrao
committed

Commits on Sep 13, 2015

KAFKA-2538: Fixing a compilation error in trunk.

Parth-Brahmbhatt
authored and
guozhangwang
committed

Commits on Sep 14, 2015

KAFKA-2504: Stop logging WARN when client disconnects

jholoman
authored and
gwenshap
committed
MINOR: Added scripts to automate Vagrant setup for system tests

Geoff Anderson
authored and
gwenshap
committed
KAFKA-2549: Fixing checkstyle failure resulting due to unused imports…

Parth-Brahmbhatt
authored and
gwenshap
committed

Commits on Sep 16, 2015

KAFKA-2120; Add a request timeout to NetworkClient (KIP-19); reviewed by Jason Gustafson, Ismael Juma, Joel Koshy, Jun Rao, and Edward Ribeiro

MayureshGharat
authored and
jjkoshy
committed

Commits on Sep 17, 2015

Revert "KAFKA-2120; Add a request timeout to NetworkClient (KIP-19); reviewed by Jason Gustafson, Ismael Juma, Joel Koshy, Jun Rao, and Edward Ribeiro"
jjkoshy
committed

Commits on Sep 21, 2015

KAFKA-2300: follow-up to clear the controller state upon resignment

fpj
authored and
guozhangwang
committed
KAFKA-2533: Create a member Metadata.Listener inside KafkaConsumer

Ashish Singh
authored and
guozhangwang
committed
KAFKA-2532; Remove Consumer reference from rebalance callback

hachikuji
authored and
guozhangwang
committed

Commits on Sep 22, 2015

KAFKA-2211: Adding simpleAclAuthorizer implementation and test cases.

Parth-Brahmbhatt
authored and
junrao
committed
KAFKA-2558: ServerShutdownTest is failing intermittently

fpj
authored and
guozhangwang
committed
KAFKA-2557: separate REBALANCE_IN_PROGRESS and ILLEGAL_GENERATION error codes

onurkaraman
authored and
guozhangwang
committed

Commits on Sep 23, 2015

KAFKA-2403; Add support for commit metadata in KafkaConsumer

hachikuji
authored and
guozhangwang
committed
KAFKA-2390; OffsetOutOfRangeException should contain the Offset and Partition info.

lindong28
authored and
guozhangwang
committed

Commits on Sep 24, 2015

KAFKA-2576; ConsumerPerformance hangs when SSL enabled for Multi-Partition Topic

ijuma
authored and
junrao
committed
KAFKA-1387: Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

fpj
authored and
junrao
committed
KAFKA-2548; kafka-merge-pr tool fails to update JIRA with fix version 0.9.0.0

ijuma
authored and
guozhangwang
committed
KAFKA-2554: change 0.8.3 to 0.9.0 in ApiVersion and other files

omkreddy
authored and
gwenshap
committed
KAFKA-2390; followup; add unit test for OffsetOutOfRange exception

lindong28
authored and
guozhangwang
committed

Commits on Sep 25, 2015

KAFKA-2373: Add Kafka-backed offset storage for Copycat.

ewencp
authored and
gwenshap
committed
KAFKA-2571; KafkaLog4jAppender dies while specifying acks config

Ashish Singh
authored and
gwenshap
committed
KAFKA-2579; prevent unauthorized clients from joining groups

hachikuji
authored and
gwenshap
committed
KAFKA-2409; have KafkaConsumer.committed return null when there is no commit

hachikuji
authored and
guozhangwang
committed
KAFKA-2555: Fix infinite recursive ensurePartitionAssignment in callback's commitSync

becketqin
authored and
guozhangwang
committed
HOTFIX: remove unused import causing checkstyle to fail

hachikuji
authored and
guozhangwang
committed
KAFKA-2582; ConsumerMetdata authorization error not returned to user

hachikuji
authored and
junrao
committed

Commits on Sep 26, 2015

KIP-28: Add a processor client for Kafka Streaming
guozhangwang
committed

Commits on Sep 27, 2015

KAFKA-2531: Add Ducktape based tests for KafkaLog4jAppender

Ashish Singh
authored and
gwenshap
committed

Commits on Sep 28, 2015

MINOR: Fix FileStreamSourceTask to create the reader around System.in when using stdin as the input source.

ewencp
authored and
gwenshap
committed
HOTFIX: Checkstye fixes follow up for KAKFA-2531.

ewencp
authored and
gwenshap
committed
KAFKA-2586; Enable SSL for inter-broker communication when SSL is enabled in tests

ijuma
authored and
junrao
committed
KAFKA-2514: change default JVM options in kafka-run-class.sh.

omkreddy
authored and
junrao
committed
KAFKA-2585; ConsoleConsumer should not hang infinitely upon exception

lindong28
authored and
gwenshap
committed
MINOR: Make indenting in `checkstyle.xml` and `import-control.xml` consistent

ijuma
authored and
gwenshap
committed

Commits on Sep 29, 2015

KAFKA-2120; Add a request timeout to NetworkClient (KIP-19); reviewed by Jason Gustafson, Ismael Juma, Joel Koshy, Jun Rao, and Edward Ribeiro

MayureshGharat
authored and
jjkoshy
committed
MINOR: fix Quota's equal() function

eribeiro
authored and
guozhangwang
committed
HOTFIX: Checkstyle import fix

ijuma
authored and
jjkoshy
committed
KAFKA-2587; Increasing timeout for the test verification.

Parth-Brahmbhatt
authored and
Sriharsha Chintalapani
committed

Commits on Sep 30, 2015

KAFKA-2570: commit offsets on rebalance/close when auto-commit is enabled

hachikuji
authored and
guozhangwang
committed

Commits on Oct 1, 2015

MINOR: Set `sendTime` in `doSend` instead of `InFlightRequests.add` and rename method names for consistency

ijuma
authored and
jjkoshy
committed

Commits on Oct 2, 2015

KAFKA-2212: Authorizer CLI implementation.

Parth-Brahmbhatt
authored and
junrao
committed
KAFKA-2517; Performance Regression post SSL implementation (zero copy)

ijuma
authored and
junrao
committed
MINOR: Fix Vagrant setup script for use on Fedora

lindong28
authored and
guozhangwang
committed
MINOR: remove no longer needed CommitType

hachikuji
authored and
guozhangwang
committed
KAFKA-2597: Add to .gitignore the Eclipse IDE directories

rhauch
authored and
guozhangwang
committed

Commits on Oct 3, 2015

KAFKA-2591: Fix StreamingMetrics
guozhangwang
committed
KAFKA-2425; Copy latest docs to kafka repo docs/ directory

omkreddy
authored and
gwenshap
committed

Commits on Oct 5, 2015

KAFKA-2601; ConsoleProducer tool shows stacktrace on invalid command parameters

GabrielNicolasAvellaneda
authored and
Sriharsha Chintalapani
committed
KAFKA-2604; Remove `completeAll` and improve timeout passed to `Selector.poll` from `NetworkClient.poll`

ijuma
authored and
guozhangwang
committed
HOTFIX: Persistent store in ProcessorStateManagerTest
guozhangwang
committed
TRIVIAL: remove TODO in KafkaConsumer after KAFKA-2120
guozhangwang
committed

Commits on Oct 6, 2015

KAFKA-2599: Fix Metadata.getClusterForCurrentTopics throws NPE

eribeiro
authored and
guozhangwang
committed
KAFKA-2573: Mirror maker system test hangs and eventually fails

Ashish Singh
authored and
guozhangwang
committed
KAFKA-2482: Allow sink tasks to get their current assignment, as well as pause and resume topic partitions.

ewencp
authored and
guozhangwang
committed
KAFKA-2474: Add caching of JSON schema conversions to JsonConverter

ewencp
authored and
guozhangwang
committed

Commits on Oct 7, 2015

KAFKA-2476: Add Decimal, Date, and Timestamp logical types.

ewencp
authored and
guozhangwang
committed
KAFKA-2534: Fixes and unit tests for SSLTransportLayer buffer overflow

rajinisivaram
authored and
junrao
committed
KAFKA-2419; Garbage collect unused sensors

Aditya Auradkar
authored and
jjkoshy
committed

Commits on Oct 8, 2015

Kafka-2587: Only notification handler will update the cache and all verifications will use waitUntilTrue.

Parth-Brahmbhatt
authored and
junrao
committed
KAFKA-2428: Add sanity check in KafkaConsumer for the timeouts

Mayuresh Gharat
authored and
guozhangwang
committed
KAFKA-2477: Fix a race condition between log append and fetch that causes OffsetOutOfRangeException.

becketqin
authored and
junrao
committed

Commits on Oct 9, 2015

MINOR: typing ProcessorDef

Yasuhiro Matsuda
authored and
guozhangwang
committed
KAFKA-2596: reject commits from unknown groups with positive generations

hachikuji
authored and
guozhangwang
committed
KAFKA-2622: Add Time logical type for Copycat.

ewencp
authored and
guozhangwang
committed
KAFKA-2600: Align Kafka Streams' interfaces with Java 8 functional interfaces

rhauch
authored and
guozhangwang
committed
MINOR: Fix exception message in Copycat's Time logical type.

ewencp
authored and
guozhangwang
committed
MINOR: putting back kstream stateful transform methods

Yasuhiro Matsuda
authored and
guozhangwang
committed

Commits on Oct 10, 2015

KAFKA-2614; No more clients can connect after `TooManyConnectionsException` threshold (max.connections.per.ip) is reached

ijuma
authored and
junrao
committed

Commits on Oct 11, 2015

MINOR: Use the correct processor id in the processor thread name

ijuma
authored and
junrao
committed

Commits on Oct 12, 2015

KAFKA-2633; Default logging from tools to Stderr

granthenke
authored and
gwenshap
committed
KAFKA-2443 KAFKA-2567; Expose windowSize on Rate; - Throttle time should not return NaN

auradkar
authored and
jjkoshy
committed
KAFKA-2203: Getting Java8 to relax about javadoc and let our build pass

gwenshap
authored and
guozhangwang
committed