Repository: kafka
Updated Branches:
refs/heads/trunk 7ebc5da60 -> 88809b9b8
HOTFIX: Verifiable producer request timeout needs conversion to milliseconds
Author: Jason Gustafson
Reviewers: Ewen Cheslack-Postava
Closes #2494 from
Repository: kafka
Updated Branches:
refs/heads/trunk 82e75b960 -> 2c0055e62
HOTFIX: Do Not use unlimited num messages in IntegrationTestUtils
Removed readKeyValues() that give UNLIMITED_MESSAGES which will doom to exhaust
all wait time, as all its callers actually do provide the expected
Repository: kafka
Updated Branches:
refs/heads/trunk 8bd8751aa -> 6c1478d19
KAFKA-4749; Fix join-time-max and sync-time-max MeasurableStat type
GroupCoordinatorMetrics currently sets up join-time-max and sync-time-max
incorrectly as a "new Avg()" MeasurableStat instead of "new Max()"
Repository: kafka
Updated Branches:
refs/heads/trunk 1f8a2ad2e -> b31a7a902
KAFKA-4728; KafkaConsumer#commitSync should copy its input
Author: Jan Lukavsky
Reviewers: Jason Gustafson
Closes #2491 from je-ik/KAFKA-4728
Project:
Repository: kafka
Updated Branches:
refs/heads/0.10.2 e321cd4f5 -> f4276b7cf
KAFKA-4728; KafkaConsumer#commitSync should copy its input
Author: Jan Lukavsky
Reviewers: Jason Gustafson
Closes #2491 from je-ik/KAFKA-4728
(cherry picked from commit
Repository: kafka
Updated Branches:
refs/heads/trunk 0b48ea1c8 -> cea461353
MINOR: Update docs for version 0.10.2.0
Author: Ewen Cheslack-Postava
Reviewers: Jason Gustafson
Closes #2480 from ewencp/docs-version-0.10.2.0
Project:
Repository: kafka
Updated Branches:
refs/heads/0.10.2 54512cbaf -> 9cf6f9790
MINOR: Update docs for version 0.10.2.0
Author: Ewen Cheslack-Postava
Reviewers: Jason Gustafson
Closes #2480 from ewencp/docs-version-0.10.2.0
(cherry picked from commit
Repository: kafka
Updated Branches:
refs/heads/trunk b948f4327 -> 5afe95964
MINOR: Logging improvements in consumer internals
Author: Jason Gustafson
Reviewers: Manikumar reddy O , Ewen Cheslack-Postava
, Ismael Juma
Repository: kafka
Updated Branches:
refs/heads/0.10.2 61024c9d2 -> a50635219
MINOR: Logging improvements in consumer internals
Author: Jason Gustafson
Reviewers: Manikumar reddy O , Ewen Cheslack-Postava
, Ismael Juma
KAFKA-4633; Always using regex pattern subscription in StreamThread
1. In StreamThread, always use subscribe(Pattern, ..) function in order to
avoid sending MetadataRequest with specific topic names and cause brokers to
possibly auto-create subscribed topics; the pattern is generated as
Repository: kafka
Updated Branches:
refs/heads/trunk 62206de4e -> 3400d0c3c
http://git-wip-us.apache.org/repos/asf/kafka/blob/3400d0c3/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java
--
diff --git
Repository: kafka
Updated Branches:
refs/heads/0.10.2 80ceb75d2 -> 0f87991d5
http://git-wip-us.apache.org/repos/asf/kafka/blob/0f87991d/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java
--
diff
Repository: kafka
Updated Branches:
refs/heads/trunk 79987590e -> bf5aebadb
MINOR: Add offset information to consumer_test error messages
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #2426 from hachikuji/improve-consumer-test-error-messages
Repository: kafka
Updated Branches:
refs/heads/trunk 5b4e299a4 -> 254e3b77d
KAFKA-4699; Invoke producer callbacks before completing the future
This behaviour was changed in 8b3c6c0, but it caused interceptor
test failures (which rely on callbacks) and since weâre so close to
code freeze,
Repository: kafka
Updated Branches:
refs/heads/0.10.2 8812d151a -> 29bc8905a
KAFKA-4699; Invoke producer callbacks before completing the future
This behaviour was changed in 8b3c6c0, but it caused interceptor
test failures (which rely on callbacks) and since weâre so close to
code freeze,
Repository: kafka
Updated Branches:
refs/heads/0.10.2 5f1ab1419 -> b2bcef7f3
MINOR: Close create topics policy during shutdown and more tests
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #2443 from
Repository: kafka
Updated Branches:
refs/heads/trunk 0971e62e5 -> 23f695196
KAFKA-4698; VerifyError in kafka/client/ClientUtils due to -target:jvm-1.7
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #2434 from
Repository: kafka
Updated Branches:
refs/heads/0.10.2 1d2426683 -> 94c0da2b7
KAFKA-4698; VerifyError in kafka/client/ClientUtils due to -target:jvm-1.7
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #2434 from
Repository: kafka
Updated Branches:
refs/heads/0.10.2 94c0da2b7 -> e74a92463
KAFKA-4597; RecordMetadata should return log append time when appropriate
There is a slight change of behaviour: we now complete the `Future` returned
from `send`
before the callbacks are invoked. This seems OK and
Repository: kafka
Updated Branches:
refs/heads/trunk 0c83eddcd -> 1eac3f33f
MINOR: Change logging level for ignored maybeAddMetric from debug to trace
Author: Guozhang Wang
Reviewers: Eno Thereska , Xavier Léauté
, Jason
Repository: kafka
Updated Branches:
refs/heads/0.10.2 f68c7e0f3 -> af4f4df18
MINOR: Change logging level for ignored maybeAddMetric from debug to trace
Author: Guozhang Wang
Reviewers: Eno Thereska , Xavier Léauté
, Jason
Repository: kafka
Updated Branches:
refs/heads/0.10.1 027455146 -> c310a1bc6
KAFKA-4547; Avoid unnecessary offset commit that could lead to an invalid
offset position if partition is paused
Author: Vahid Hashemian
Reviewers: Jason Gustafson
MINOR: Remove Struct from Request/Response classes
More details:
* Replaced `struct` field in Request/Response with a `toStruct` method. This
makes the performance model (including memory usage) easier to understand.
Note that requests have `toStruct()` while responses have `toStruct(version)`.
*
Repository: kafka
Updated Branches:
refs/heads/trunk 1f2ee5f0a -> fc1cfe475
http://git-wip-us.apache.org/repos/asf/kafka/blob/fc1cfe47/core/src/test/scala/unit/kafka/server/BaseRequestTest.scala
--
diff --git
http://git-wip-us.apache.org/repos/asf/kafka/blob/fc1cfe47/clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java
--
diff --git
a/clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java
http://git-wip-us.apache.org/repos/asf/kafka/blob/fc1cfe47/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/kafka/blob/fc1cfe47/clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java
--
diff --git
Repository: kafka
Updated Branches:
refs/heads/trunk 6c839395b -> 022d2017a
MINOR: Move compression stream construction into CompressionType
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #2536 from
Repository: kafka
Updated Branches:
refs/heads/trunk 1f1e794ad -> a515e9357
HOTFIX: ClassCastException in request logging
Author: Jason Gustafson
Reviewers: Colin P. Mccabe , Ewen Cheslack-Postava
Closes #2566 from
Repository: kafka
Updated Branches:
refs/heads/trunk 913c09e4a -> 5916ef022
KAFKA-4786; Wait for heartbeat thread to terminate in consumer close
Author: Rajini Sivaram
Reviewers: Apurva Mehta , Ismael Juma ,
Jason
Repository: kafka
Updated Branches:
refs/heads/0.10.2 c231f5280 -> ba4eafa78
KAFKA-4786; Wait for heartbeat thread to terminate in consumer close
Author: Rajini Sivaram
Reviewers: Apurva Mehta , Ismael Juma ,
Jason
Repository: kafka
Updated Branches:
refs/heads/trunk 151b23689 -> 0483a0b0b
MINOR: Fix transient failure of testCannotSendToInternalTopic
Itâs a simple matter of creating the internal topic before trying to send
to it. Otherwise, we could get an `UnknownTopicOrPartitionException`
in some
Repository: kafka
Updated Branches:
refs/heads/0.10.2 ac05c343a -> a9f4b671f
MINOR: Ensure consumer calls poll() if requests are outstanding
Author: Jason Gustafson
Reviewers: Onur Karaman , Ismael Juma
Closes #2596 from
Repository: kafka
Updated Branches:
refs/heads/trunk 43524442d -> b917af190
MINOR: Make it impossible to invoke `Request.body` without an explicit type
parameter
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #2579 from ijuma/safer-body
Repository: kafka
Updated Branches:
refs/heads/trunk b917af190 -> 374983263
MINOR: Ensure consumer calls poll() if requests are outstanding
Author: Jason Gustafson
Reviewers: Onur Karaman , Ismael Juma
Closes #2596 from
Repository: kafka
Updated Branches:
refs/heads/trunk 0483a0b0b -> 43524442d
MINOR: Fixed Non-Final Close Method + its Duplication
Author: Armin Braun
Reviewers: Ismael Juma , Jason Gustafson
Closes #2582 from
MINOR: Move ProtoUtils methods to ApiKeys
Also move `requireTimestamp` to `minVersion` logic from `Fetcher` to
`ListOffsetRequest.Builder.forConsumer()`.
Author: Ismael Juma
Reviewers: Colin P. Mccabe , Jason Gustafson
Closes
Repository: kafka
Updated Branches:
refs/heads/trunk 5916ef022 -> 015f1d738
http://git-wip-us.apache.org/repos/asf/kafka/blob/015f1d73/clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java
--
diff
Repository: kafka
Updated Branches:
refs/heads/trunk 3db3d73de -> e41e78200
KAFKA-4776; Implement graceful handling for improperly formed compressed
message sets
Author: Jason Gustafson
Reviewers: Jiangjie Qin
Closes #2572 from
Repository: kafka
Updated Branches:
refs/heads/trunk dcea49856 -> d24d932ef
HOTFIX: ClassCastException in Request error logging
Fixed ClassCastException resulting from missing type hint in request logging.
Author: Armin Braun
Reviewers: Jason Gustafson
Repository: kafka
Updated Branches:
refs/heads/trunk 916edc3a4 -> dcea49856
KAFKA-4777; Backoff properly in consumer heartbeat thread if no brokers are
available
Author: Allen Xiang
Reviewers: Jason Gustafson
Closes #2564 from
Repository: kafka
Updated Branches:
refs/heads/0.10.2 dfbe944e9 -> 71a511c34
KAFKA-4761; Fix producer regression handling small or zero batch size
Author: Jason Gustafson
Reviewers: Apurva Mehta , Vahid Hashemian
,
MINOR: Use an explicit `Errors` object when possible instead of a numeric error
code
Author: Vahid Hashemian
Reviewers: Ismael Juma , Jason Gustafson
Closes #2475 from
http://git-wip-us.apache.org/repos/asf/kafka/blob/9898d665/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/kafka/blob/9898d665/clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataResponse.java
--
diff --git
Repository: kafka
Updated Branches:
refs/heads/trunk a15fcea79 -> 9898d665d
http://git-wip-us.apache.org/repos/asf/kafka/blob/9898d665/core/src/test/scala/unit/kafka/coordinator/GroupCoordinatorResponseTest.scala
--
diff --git
Repository: kafka
Updated Branches:
refs/heads/trunk 260d487cd -> 5dabca025
KAFKA-4758; Connect missing checks for NO_TIMESTAMP
Author: rnpridgeon
Reviewers: Ewen Cheslack-Postava , Jason Gustafson
Closes #2533 from
Repository: kafka
Updated Branches:
refs/heads/trunk 55abe65e0 -> 7a84b241e
MINOR: Some cleanups and additional testing for KIP-88
Author: Jason Gustafson
Reviewers: Vahid Hashemian , Ismael Juma
Closes #2383 from
Repository: kafka
Updated Branches:
refs/heads/trunk fd6d7bcf3 -> 1974e1b0e
KAFKA-3502; move RocksDB options construction to init()
In RocksDBStore, options / wOptions / fOptions are constructed in the
constructor, which needs to be dismissed in the close() call; however in some
tests, the
Repository: kafka
Updated Branches:
refs/heads/0.10.2 eb62e5695 -> e38794e02
KAFKA-3502; move RocksDB options construction to init()
In RocksDBStore, options / wOptions / fOptions are constructed in the
constructor, which needs to be dismissed in the close() call; however in some
tests, the
Repository: kafka
Updated Branches:
refs/heads/trunk 5fc530bc4 -> 813897a00
KAFKA-4547; Avoid incorrect reset of paused partitions to the committed offsets
Author: Vahid Hashemian
Reviewers: Jason Gustafson
Closes #2341 from
Repository: kafka
Updated Branches:
refs/heads/0.10.2 770bab399 -> 17dd4db29
KAFKA-4547; Avoid incorrect reset of paused partitions to the committed offsets
Author: Vahid Hashemian
Reviewers: Jason Gustafson
Closes #2341 from
Repository: kafka
Updated Branches:
refs/heads/trunk 3a244b783 -> ca3f3a492
MINOR: Document that Connect topics should use compaction
Update documentation for Kafka Connect distributedâs config.storage.topic,
offset.storage.topic, and status.storage.topic configuration values to indicate
Repository: kafka
Updated Branches:
refs/heads/trunk 69ebf6f7b -> 6cf2cb6f2
KAFKA-4139; Reset findCoordinatorFuture when brokers are unavailable
Author: Rajini Sivaram
Reviewers: Ismael Juma, Jason Gustafson
Closes #1831 from rajinisivaram/KAFKA-4139
Repository: kafka
Updated Branches:
refs/heads/trunk eb59c8124 -> 54767bbba
KAFKA-4033; Revise partition assignment semantics on consumer subscription
changes (KIP-70)
This PR changes topic subscription semantics so a change in subscription does
not immediately cause a rebalance.
Instead,
Repository: kafka
Updated Branches:
refs/heads/trunk a7ab9cb83 -> 2a660f13d
KAFKA-2311; Make KafkaConsumer's ensureNotClosed method thread-safe
Here is the patch on github ijuma.
Acquiring the consumer lock (the single thread access controls) requires that
the consumer be open. I changed
Repository: kafka
Updated Branches:
refs/heads/0.10.1 823c08067 -> 6b8bcf65e
KAFKA-3831; Prepare for updating new-consumer-based Mirror Maker's default
partition assignment strategy to round robin
This patch adds proper warning message and necessary doc updates for updating
the default
Repository: kafka
Updated Branches:
refs/heads/trunk be6056abc -> 60ad6d727
KAFKA-3831; Prepare for updating new-consumer-based Mirror Maker's default
partition assignment strategy to round robin
This patch adds proper warning message and necessary doc updates for updating
the default
Repository: kafka
Updated Branches:
refs/heads/0.10.1 2a059fa68 -> 7de050ee5
KAFKA-3697; Clean up website documentation of client usage
This is to imply that the Java consumer/producer are the recommended
consumer/producer now.
Author: Vahid Hashemian
Reviewers:
Repository: kafka
Updated Branches:
refs/heads/trunk 7c6d70655 -> d2a267b11
KAFKA-3697; Clean up website documentation of client usage
This is to imply that the Java consumer/producer are the recommended
consumer/producer now.
Author: Vahid Hashemian
Reviewers:
Repository: kafka-site
Updated Branches:
refs/heads/asf-site 590fd7083 -> aa684e574
theme enhancements for mobile and branding guidelines
rewrite rules added to prevent users from loading up html files meant to be
partials
add notification over past versions of docs and rename partials
Repository: kafka
Updated Branches:
refs/heads/0.10.1 41b12a6ad -> 017defcd1
KAFKA-4165; Add 0.10.0.1 as a source for compatibility tests
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #1959 from hachikuji/KAFKA-4165
(cherry picked from
Repository: kafka
Updated Branches:
refs/heads/0.10.1 017defcd1 -> e51c4cf99
Bump version to 0.10.1.0
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e51c4cf9
Tree:
Repository: kafka
Updated Branches:
refs/heads/0.10.1 e51c4cf99 -> 017defcd1 (forced update)
Repository: kafka
Updated Branches:
refs/heads/trunk 1a396c9cf -> d8d2f3aac
MINOR: Tweak upgrade note on KIP-62 to include request.timeout.ms
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #1960 from hachikuji/add-note-on-request-timeout
Repository: kafka
Updated Branches:
refs/heads/0.10.1 aafc86928 -> 41b12a6ad
MINOR: Tweak upgrade note on KIP-62 to include request.timeout.ms
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #1960 from hachikuji/add-note-on-request-timeout
Repository: kafka
Updated Branches:
refs/heads/trunk d8d2f3aac -> b3eef7bc7
KAFKA-4165; Add 0.10.0.1 as a source for compatibility tests
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #1959 from hachikuji/KAFKA-4165
Project:
Repository: kafka
Updated Branches:
refs/heads/0.10.1 017defcd1 -> f4c186d31
MINOR: Update documentation for 0.10.1 release
Author: Jason Gustafson
Reviewers: Gwen Shapira
Closes #1963 from hachikuji/update-docs-for-0.10.1
Project:
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/consumer/ConsumerConfig.html
--
diff --git a/0101/javadoc/org/apache/kafka/clients/consumer/ConsumerConfig.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/RecordTooLargeException.html
--
diff --git
a/0101/javadoc/org/apache/kafka/common/errors/RecordTooLargeException.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/ControllerMovedException.html
--
diff --git
a/0101/javadoc/org/apache/kafka/common/errors/ControllerMovedException.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/NetworkException.html
--
diff --git a/0101/javadoc/org/apache/kafka/common/errors/NetworkException.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/connect/data/Decimal.html
--
diff --git a/0101/javadoc/org/apache/kafka/connect/data/Decimal.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/config/SslConfigs.html
--
diff --git a/0101/javadoc/org/apache/kafka/common/config/SslConfigs.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/serialization/Serdes.html
--
diff --git a/0101/javadoc/org/apache/kafka/common/serialization/Serdes.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/consumer/OffsetResetStrategy.html
--
diff --git
a/0101/javadoc/org/apache/kafka/clients/consumer/OffsetResetStrategy.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html
--
diff --git a/0101/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/connect/data/Struct.html
--
diff --git a/0101/javadoc/org/apache/kafka/connect/data/Struct.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html
--
diff --git a/0101/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/package-frame.html
--
diff --git a/0101/javadoc/org/apache/kafka/common/errors/package-frame.html
Repository: kafka-site
Updated Branches:
refs/heads/asf-site ed0bb0d98 -> 2d621da3b
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/connect/sink/SinkConnector.html
--
diff --git
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/InvalidOffsetException.html
--
diff --git
a/0101/javadoc/org/apache/kafka/common/errors/InvalidOffsetException.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/consumer/package-summary.html
--
diff --git
a/0101/javadoc/org/apache/kafka/clients/consumer/package-summary.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/connect/data/Schema.html
--
diff --git a/0101/javadoc/org/apache/kafka/connect/data/Schema.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/producer/MockProducer.html
--
diff --git a/0101/javadoc/org/apache/kafka/clients/producer/MockProducer.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html
--
diff --git a/0101/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/config/ConfigException.html
--
diff --git a/0101/javadoc/org/apache/kafka/common/config/ConfigException.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/serialization/LongDeserializer.html
--
diff --git
a/0101/javadoc/org/apache/kafka/common/serialization/LongDeserializer.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/ApiException.html
--
diff --git a/0101/javadoc/org/apache/kafka/common/errors/ApiException.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.html
--
diff --git
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/deprecated-list.html
--
diff --git a/0101/javadoc/deprecated-list.html
b/0101/javadoc/deprecated-list.html
new file mode 100644
index 000..1aed704
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/producer/ProducerConfig.html
--
diff --git a/0101/javadoc/org/apache/kafka/clients/producer/ProducerConfig.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/connect/connector/Task.html
--
diff --git a/0101/javadoc/org/apache/kafka/connect/connector/Task.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/connect/data/package-tree.html
--
diff --git a/0101/javadoc/org/apache/kafka/connect/data/package-tree.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/serialization/Deserializer.html
--
diff --git
a/0101/javadoc/org/apache/kafka/common/serialization/Deserializer.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/constant-values.html
--
diff --git a/0101/javadoc/constant-values.html
b/0101/javadoc/constant-values.html
new file mode 100644
index 000..afdd210
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html
--
diff --git
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/serialization/package-summary.html
--
diff --git
a/0101/javadoc/org/apache/kafka/common/serialization/package-summary.html
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/InvalidRequiredAcksException.html
--
diff --git
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/org/apache/kafka/common/errors/InvalidCommitOffsetSizeException.html
--
diff --git
1 - 100 of 2118 matches
Mail list logo