You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ne...@apache.org on 2011/10/07 21:51:30 UTC
svn commit: r1180185 [1/2] - in /incubator/kafka/trunk: bin/
clients/clojure/ clients/clojure/leiningen/ clients/clojure/resources/
clients/clojure/src/kafka/ clients/clojure/test/kafka/
clients/cpp/build-aux/ clients/php/src/examples/ clients/php/src/...
Author: nehanarkhede
Date: Fri Oct 7 19:51:28 2011
New Revision: 1180185
URL: http://svn.apache.org/viewvc?rev=1180185&view=rev
Log:
KAFKA-141 Check and make sure that the files that have been donated have been updated to reflect the new ASF copyright;patched by nehanarkhede; reviewd by jjkoshy
Modified:
incubator/kafka/trunk/bin/kafka-console-consumer-log4j.properties
incubator/kafka/trunk/bin/kafka-console-consumer.sh
incubator/kafka/trunk/bin/kafka-console-producer.sh
incubator/kafka/trunk/bin/kafka-consumer-perf-test.sh
incubator/kafka/trunk/bin/kafka-consumer-shell.sh
incubator/kafka/trunk/bin/kafka-producer-perf-test.sh
incubator/kafka/trunk/bin/kafka-producer-shell.sh
incubator/kafka/trunk/bin/kafka-replay-log-producer.sh
incubator/kafka/trunk/bin/kafka-run-class.sh
incubator/kafka/trunk/bin/kafka-server-start.sh
incubator/kafka/trunk/bin/kafka-server-stop.sh
incubator/kafka/trunk/bin/kafka-simple-consumer-perf-test.sh
incubator/kafka/trunk/bin/kafka-simple-consumer-shell.sh
incubator/kafka/trunk/bin/zookeeper-server-start.sh
incubator/kafka/trunk/bin/zookeeper-server-stop.sh
incubator/kafka/trunk/clients/clojure/leiningen/run_example.clj
incubator/kafka/trunk/clients/clojure/project.clj
incubator/kafka/trunk/clients/clojure/resources/log4j.properties
incubator/kafka/trunk/clients/clojure/src/kafka/buffer.clj
incubator/kafka/trunk/clients/clojure/src/kafka/example.clj
incubator/kafka/trunk/clients/clojure/src/kafka/kafka.clj
incubator/kafka/trunk/clients/clojure/src/kafka/print.clj
incubator/kafka/trunk/clients/clojure/src/kafka/serializable.clj
incubator/kafka/trunk/clients/clojure/src/kafka/types.clj
incubator/kafka/trunk/clients/clojure/test/kafka/buffer_test.clj
incubator/kafka/trunk/clients/clojure/test/kafka/print_test.clj
incubator/kafka/trunk/clients/clojure/test/kafka/serializable_test.clj
incubator/kafka/trunk/clients/cpp/build-aux/install-sh
incubator/kafka/trunk/clients/cpp/build-aux/ltmain.sh
incubator/kafka/trunk/clients/php/src/examples/autoloader.php
incubator/kafka/trunk/clients/php/src/examples/consume.php
incubator/kafka/trunk/clients/php/src/examples/produce.php
incubator/kafka/trunk/clients/php/src/tests/Kafka/BoundedByteBuffer/ReceiveTest.php
incubator/kafka/trunk/clients/php/src/tests/Kafka/BoundedByteBuffer/SendTest.php
incubator/kafka/trunk/clients/php/src/tests/Kafka/EncoderTest.php
incubator/kafka/trunk/clients/php/src/tests/Kafka/FetchRequestTest.php
incubator/kafka/trunk/clients/php/src/tests/Kafka/MessageTest.php
incubator/kafka/trunk/clients/php/src/tests/Kafka/ProducerTest.php
incubator/kafka/trunk/clients/php/src/tests/bootstrap.php
incubator/kafka/trunk/clients/ruby/lib/kafka.rb
incubator/kafka/trunk/clients/ruby/lib/kafka/batch.rb
incubator/kafka/trunk/clients/ruby/lib/kafka/consumer.rb
incubator/kafka/trunk/clients/ruby/lib/kafka/error_codes.rb
incubator/kafka/trunk/clients/ruby/lib/kafka/io.rb
incubator/kafka/trunk/clients/ruby/lib/kafka/message.rb
incubator/kafka/trunk/clients/ruby/lib/kafka/producer.rb
incubator/kafka/trunk/clients/ruby/lib/kafka/request_type.rb
incubator/kafka/trunk/clients/ruby/spec/batch_spec.rb
incubator/kafka/trunk/clients/ruby/spec/consumer_spec.rb
incubator/kafka/trunk/clients/ruby/spec/io_spec.rb
incubator/kafka/trunk/clients/ruby/spec/kafka_spec.rb
incubator/kafka/trunk/clients/ruby/spec/message_spec.rb
incubator/kafka/trunk/clients/ruby/spec/producer_spec.rb
incubator/kafka/trunk/clients/ruby/spec/spec_helper.rb
incubator/kafka/trunk/config/consumer.properties
incubator/kafka/trunk/config/log4j.properties
incubator/kafka/trunk/config/server.properties
incubator/kafka/trunk/config/zookeeper.properties
incubator/kafka/trunk/contrib/hadoop-consumer/copy-jars.sh
incubator/kafka/trunk/contrib/hadoop-consumer/hadoop-setup.sh
incubator/kafka/trunk/contrib/hadoop-consumer/run-class.sh
incubator/kafka/trunk/contrib/hadoop-consumer/test/test.properties
incubator/kafka/trunk/core/src/test/resources/log4j.properties
incubator/kafka/trunk/core/src/test/scala/other/kafka.log4j.properties
incubator/kafka/trunk/examples/bin/java-producer-consumer-demo.sh
incubator/kafka/trunk/examples/bin/java-simple-consumer-demo.sh
incubator/kafka/trunk/project/build.properties
incubator/kafka/trunk/system_test/embedded_consumer/bin/run-test.sh
incubator/kafka/trunk/system_test/embedded_consumer/config/blacklisttest.consumer.properties
incubator/kafka/trunk/system_test/embedded_consumer/config/consumer.properties
incubator/kafka/trunk/system_test/embedded_consumer/config/mirror_producer.properties
incubator/kafka/trunk/system_test/embedded_consumer/config/server_source1.properties
incubator/kafka/trunk/system_test/embedded_consumer/config/server_source2.properties
incubator/kafka/trunk/system_test/embedded_consumer/config/server_source3.properties
incubator/kafka/trunk/system_test/embedded_consumer/config/server_target1.properties
incubator/kafka/trunk/system_test/embedded_consumer/config/server_target2.properties
incubator/kafka/trunk/system_test/embedded_consumer/config/whitelisttest.consumer.properties
incubator/kafka/trunk/system_test/embedded_consumer/config/zookeeper_source.properties
incubator/kafka/trunk/system_test/embedded_consumer/config/zookeeper_target.properties
incubator/kafka/trunk/system_test/producer_perf/bin/run-compression-test.sh
incubator/kafka/trunk/system_test/producer_perf/bin/run-test.sh
incubator/kafka/trunk/system_test/producer_perf/config/server.properties
incubator/kafka/trunk/system_test/producer_perf/config/zookeeper.properties
Modified: incubator/kafka/trunk/bin/kafka-console-consumer-log4j.properties
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/bin/kafka-console-consumer-log4j.properties?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/bin/kafka-console-consumer-log4j.properties (original)
+++ incubator/kafka/trunk/bin/kafka-console-consumer-log4j.properties Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
log4j.rootLogger=INFO, stderr
log4j.appender.stderr=org.apache.log4j.ConsoleAppender
Modified: incubator/kafka/trunk/bin/kafka-console-consumer.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/bin/kafka-console-consumer.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/bin/kafka-console-consumer.sh (original)
+++ incubator/kafka/trunk/bin/kafka-console-consumer.sh Fri Oct 7 19:51:28 2011
@@ -1,4 +1,18 @@
#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
base_dir=$(dirname $0)
export KAFKA_OPTS="-Xmx512M -server -Dcom.sun.management.jmxremote -Dlog4j.configuration=file:$base_dir/kafka-console-consumer-log4j.properties"
Modified: incubator/kafka/trunk/bin/kafka-console-producer.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/bin/kafka-console-producer.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/bin/kafka-console-producer.sh (original)
+++ incubator/kafka/trunk/bin/kafka-console-producer.sh Fri Oct 7 19:51:28 2011
@@ -1,4 +1,18 @@
#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
base_dir=$(dirname $0)
$base_dir/kafka-run-class.sh kafka.producer.ConsoleProducer $@
Modified: incubator/kafka/trunk/bin/kafka-consumer-perf-test.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/bin/kafka-consumer-perf-test.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/bin/kafka-consumer-perf-test.sh (original)
+++ incubator/kafka/trunk/bin/kafka-consumer-perf-test.sh Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
$(dirname $0)/kafka-run-class.sh kafka.tools.ConsumerPerformance $@
Modified: incubator/kafka/trunk/bin/kafka-consumer-shell.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/bin/kafka-consumer-shell.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/bin/kafka-consumer-shell.sh (original)
+++ incubator/kafka/trunk/bin/kafka-consumer-shell.sh Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
$(dirname $0)/kafka-run-class.sh kafka.tools.ConsumerShell $@
Modified: incubator/kafka/trunk/bin/kafka-producer-perf-test.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/bin/kafka-producer-perf-test.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/bin/kafka-producer-perf-test.sh (original)
+++ incubator/kafka/trunk/bin/kafka-producer-perf-test.sh Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
$(dirname $0)/kafka-run-class.sh kafka.tools.ProducerPerformance $@
Modified: incubator/kafka/trunk/bin/kafka-producer-shell.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/bin/kafka-producer-shell.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/bin/kafka-producer-shell.sh (original)
+++ incubator/kafka/trunk/bin/kafka-producer-shell.sh Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
$(dirname $0)/kafka-run-class.sh kafka.tools.ProducerShell $@
Modified: incubator/kafka/trunk/bin/kafka-replay-log-producer.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/bin/kafka-replay-log-producer.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/bin/kafka-replay-log-producer.sh (original)
+++ incubator/kafka/trunk/bin/kafka-replay-log-producer.sh Fri Oct 7 19:51:28 2011
@@ -1,4 +1,18 @@
#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
base_dir=$(dirname $0)
export KAFKA_OPTS="-Xmx512M -server -Dcom.sun.management.jmxremote -Dlog4j.configuration=file:$base_dir/../config/log4j.properties"
Modified: incubator/kafka/trunk/bin/kafka-run-class.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/bin/kafka-run-class.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/bin/kafka-run-class.sh (original)
+++ incubator/kafka/trunk/bin/kafka-run-class.sh Fri Oct 7 19:51:28 2011
@@ -1,4 +1,18 @@
#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
if [ $# -lt 1 ];
then
Modified: incubator/kafka/trunk/bin/kafka-server-start.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/bin/kafka-server-start.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/bin/kafka-server-start.sh (original)
+++ incubator/kafka/trunk/bin/kafka-server-start.sh Fri Oct 7 19:51:28 2011
@@ -1,4 +1,18 @@
#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
if [ $# -lt 1 ];
then
Modified: incubator/kafka/trunk/bin/kafka-server-stop.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/bin/kafka-server-stop.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/bin/kafka-server-stop.sh (original)
+++ incubator/kafka/trunk/bin/kafka-server-stop.sh Fri Oct 7 19:51:28 2011
@@ -1,2 +1,16 @@
#!/bin/sh
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
ps ax | grep -i 'kafka.Kafka' | grep -v grep | awk '{print $1}' | xargs kill -SIGINT
Modified: incubator/kafka/trunk/bin/kafka-simple-consumer-perf-test.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/bin/kafka-simple-consumer-perf-test.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/bin/kafka-simple-consumer-perf-test.sh (original)
+++ incubator/kafka/trunk/bin/kafka-simple-consumer-perf-test.sh Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
$(dirname $0)/kafka-run-class.sh kafka.tools.SimpleConsumerPerformance $@
Modified: incubator/kafka/trunk/bin/kafka-simple-consumer-shell.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/bin/kafka-simple-consumer-shell.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/bin/kafka-simple-consumer-shell.sh (original)
+++ incubator/kafka/trunk/bin/kafka-simple-consumer-shell.sh Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
$(dirname $0)/kafka-run-class.sh kafka.tools.SimpleConsumerShell $@
Modified: incubator/kafka/trunk/bin/zookeeper-server-start.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/bin/zookeeper-server-start.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/bin/zookeeper-server-start.sh (original)
+++ incubator/kafka/trunk/bin/zookeeper-server-start.sh Fri Oct 7 19:51:28 2011
@@ -1,4 +1,18 @@
#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
if [ $# -ne 1 ];
then
@@ -6,4 +20,4 @@ then
exit 1
fi
-$(dirname $0)/kafka-run-class.sh org.apache.zookeeper.server.quorum.QuorumPeerMain $@
\ No newline at end of file
+$(dirname $0)/kafka-run-class.sh org.apache.zookeeper.server.quorum.QuorumPeerMain $@
Modified: incubator/kafka/trunk/bin/zookeeper-server-stop.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/bin/zookeeper-server-stop.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/bin/zookeeper-server-stop.sh (original)
+++ incubator/kafka/trunk/bin/zookeeper-server-stop.sh Fri Oct 7 19:51:28 2011
@@ -1,2 +1,16 @@
#!/bin/sh
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
ps ax | grep -i 'zookeeper' | grep -v grep | awk '{print $1}' | xargs kill -SIGINT
Modified: incubator/kafka/trunk/clients/clojure/leiningen/run_example.clj
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/clojure/leiningen/run_example.clj?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/clojure/leiningen/run_example.clj (original)
+++ incubator/kafka/trunk/clients/clojure/leiningen/run_example.clj Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+;; Licensed to the Apache Software Foundation (ASF) under one or more
+;; contributor license agreements. See the NOTICE file distributed with
+;; this work for additional information regarding copyright ownership.
+;; The ASF licenses this file to You under the Apache License, Version 2.0
+;; (the "License"); you may not use this file except in compliance with
+;; the License. You may obtain a copy of the License at
+;;
+;; http://www.apache.org/licenses/LICENSE-2.0
+;;
+;; Unless required by applicable law or agreed to in writing, software
+;; distributed under the License is distributed on an "AS IS" BASIS,
+;; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+;; See the License for the specific language governing permissions and
+;; limitations under the License.
(ns leiningen.run-example
(:use [leiningen.compile :only (eval-in-project)]))
Modified: incubator/kafka/trunk/clients/clojure/project.clj
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/clojure/project.clj?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/clojure/project.clj (original)
+++ incubator/kafka/trunk/clients/clojure/project.clj Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+;; Licensed to the Apache Software Foundation (ASF) under one or more
+;; contributor license agreements. See the NOTICE file distributed with
+;; this work for additional information regarding copyright ownership.
+;; The ASF licenses this file to You under the Apache License, Version 2.0
+;; (the "License"); you may not use this file except in compliance with
+;; the License. You may obtain a copy of the License at
+;;
+;; http://www.apache.org/licenses/LICENSE-2.0
+;;
+;; Unless required by applicable law or agreed to in writing, software
+;; distributed under the License is distributed on an "AS IS" BASIS,
+;; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+;; See the License for the specific language governing permissions and
+;; limitations under the License.
(defproject kafka-clj "0.1-SNAPSHOT"
:description "Kafka client for Clojure."
:url "http://sna-projects.com/kafka/"
Modified: incubator/kafka/trunk/clients/clojure/resources/log4j.properties
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/clojure/resources/log4j.properties?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/clojure/resources/log4j.properties (original)
+++ incubator/kafka/trunk/clients/clojure/resources/log4j.properties Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
log4j.rootLogger=INFO, A1
log4j.appender.A1=org.apache.log4j.ConsoleAppender
Modified: incubator/kafka/trunk/clients/clojure/src/kafka/buffer.clj
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/clojure/src/kafka/buffer.clj?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/clojure/src/kafka/buffer.clj (original)
+++ incubator/kafka/trunk/clients/clojure/src/kafka/buffer.clj Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+;; Licensed to the Apache Software Foundation (ASF) under one or more
+;; contributor license agreements. See the NOTICE file distributed with
+;; this work for additional information regarding copyright ownership.
+;; The ASF licenses this file to You under the Apache License, Version 2.0
+;; (the "License"); you may not use this file except in compliance with
+;; the License. You may obtain a copy of the License at
+;;
+;; http://www.apache.org/licenses/LICENSE-2.0
+;;
+;; Unless required by applicable law or agreed to in writing, software
+;; distributed under the License is distributed on an "AS IS" BASIS,
+;; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+;; See the License for the specific language governing permissions and
+;; limitations under the License.
(ns #^{:doc "Wrapper around ByteBuffer,
provides a DSL to model byte messages."}
kafka.buffer
Modified: incubator/kafka/trunk/clients/clojure/src/kafka/example.clj
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/clojure/src/kafka/example.clj?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/clojure/src/kafka/example.clj (original)
+++ incubator/kafka/trunk/clients/clojure/src/kafka/example.clj Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+;; Licensed to the Apache Software Foundation (ASF) under one or more
+;; contributor license agreements. See the NOTICE file distributed with
+;; this work for additional information regarding copyright ownership.
+;; The ASF licenses this file to You under the Apache License, Version 2.0
+;; (the "License"); you may not use this file except in compliance with
+;; the License. You may obtain a copy of the License at
+;;
+;; http://www.apache.org/licenses/LICENSE-2.0
+;;
+;; Unless required by applicable law or agreed to in writing, software
+;; distributed under the License is distributed on an "AS IS" BASIS,
+;; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+;; See the License for the specific language governing permissions and
+;; limitations under the License.
(ns #^{:doc "Producer/Consumer example."}
kafka.example
(:use (clojure.contrib logging)
Modified: incubator/kafka/trunk/clients/clojure/src/kafka/kafka.clj
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/clojure/src/kafka/kafka.clj?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/clojure/src/kafka/kafka.clj (original)
+++ incubator/kafka/trunk/clients/clojure/src/kafka/kafka.clj Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+;; Licensed to the Apache Software Foundation (ASF) under one or more
+;; contributor license agreements. See the NOTICE file distributed with
+;; this work for additional information regarding copyright ownership.
+;; The ASF licenses this file to You under the Apache License, Version 2.0
+;; (the "License"); you may not use this file except in compliance with
+;; the License. You may obtain a copy of the License at
+;;
+;; http://www.apache.org/licenses/LICENSE-2.0
+;;
+;; Unless required by applicable law or agreed to in writing, software
+;; distributed under the License is distributed on an "AS IS" BASIS,
+;; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+;; See the License for the specific language governing permissions and
+;; limitations under the License.
(ns #^{:doc "Core kafka-clj module,
provides producer and consumer factories."}
kafka.kafka
Modified: incubator/kafka/trunk/clients/clojure/src/kafka/print.clj
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/clojure/src/kafka/print.clj?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/clojure/src/kafka/print.clj (original)
+++ incubator/kafka/trunk/clients/clojure/src/kafka/print.clj Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+;; Licensed to the Apache Software Foundation (ASF) under one or more
+;; contributor license agreements. See the NOTICE file distributed with
+;; this work for additional information regarding copyright ownership.
+;; The ASF licenses this file to You under the Apache License, Version 2.0
+;; (the "License"); you may not use this file except in compliance with
+;; the License. You may obtain a copy of the License at
+;;
+;; http://www.apache.org/licenses/LICENSE-2.0
+;;
+;; Unless required by applicable law or agreed to in writing, software
+;; distributed under the License is distributed on an "AS IS" BASIS,
+;; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+;; See the License for the specific language governing permissions and
+;; limitations under the License.
(ns #^{:doc "Basic Clojure print-dup -> read-string message serialization."}
kafka.print
(:use kafka.types)
Modified: incubator/kafka/trunk/clients/clojure/src/kafka/serializable.clj
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/clojure/src/kafka/serializable.clj?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/clojure/src/kafka/serializable.clj (original)
+++ incubator/kafka/trunk/clients/clojure/src/kafka/serializable.clj Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+;; Licensed to the Apache Software Foundation (ASF) under one or more
+;; contributor license agreements. See the NOTICE file distributed with
+;; this work for additional information regarding copyright ownership.
+;; The ASF licenses this file to You under the Apache License, Version 2.0
+;; (the "License"); you may not use this file except in compliance with
+;; the License. You may obtain a copy of the License at
+;;
+;; http://www.apache.org/licenses/LICENSE-2.0
+;;
+;; Unless required by applicable law or agreed to in writing, software
+;; distributed under the License is distributed on an "AS IS" BASIS,
+;; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+;; See the License for the specific language governing permissions and
+;; limitations under the License.
(ns #^{:doc "Serialization for all Java Serializable objects."}
kafka.serializable
(:use kafka.types)
Modified: incubator/kafka/trunk/clients/clojure/src/kafka/types.clj
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/clojure/src/kafka/types.clj?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/clojure/src/kafka/types.clj (original)
+++ incubator/kafka/trunk/clients/clojure/src/kafka/types.clj Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+;; Licensed to the Apache Software Foundation (ASF) under one or more
+;; contributor license agreements. See the NOTICE file distributed with
+;; this work for additional information regarding copyright ownership.
+;; The ASF licenses this file to You under the Apache License, Version 2.0
+;; (the "License"); you may not use this file except in compliance with
+;; the License. You may obtain a copy of the License at
+;;
+;; http://www.apache.org/licenses/LICENSE-2.0
+;;
+;; Unless required by applicable law or agreed to in writing, software
+;; distributed under the License is distributed on an "AS IS" BASIS,
+;; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+;; See the License for the specific language governing permissions and
+;; limitations under the License.
(ns #^{:doc "Base kafka-clj types."}
kafka.types)
Modified: incubator/kafka/trunk/clients/clojure/test/kafka/buffer_test.clj
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/clojure/test/kafka/buffer_test.clj?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/clojure/test/kafka/buffer_test.clj (original)
+++ incubator/kafka/trunk/clients/clojure/test/kafka/buffer_test.clj Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+;; Licensed to the Apache Software Foundation (ASF) under one or more
+;; contributor license agreements. See the NOTICE file distributed with
+;; this work for additional information regarding copyright ownership.
+;; The ASF licenses this file to You under the Apache License, Version 2.0
+;; (the "License"); you may not use this file except in compliance with
+;; the License. You may obtain a copy of the License at
+;;
+;; http://www.apache.org/licenses/LICENSE-2.0
+;;
+;; Unless required by applicable law or agreed to in writing, software
+;; distributed under the License is distributed on an "AS IS" BASIS,
+;; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+;; See the License for the specific language governing permissions and
+;; limitations under the License.
(ns kafka.buffer-test
(:use (kafka buffer)
clojure.test))
Modified: incubator/kafka/trunk/clients/clojure/test/kafka/print_test.clj
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/clojure/test/kafka/print_test.clj?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/clojure/test/kafka/print_test.clj (original)
+++ incubator/kafka/trunk/clients/clojure/test/kafka/print_test.clj Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+;; Licensed to the Apache Software Foundation (ASF) under one or more
+;; contributor license agreements. See the NOTICE file distributed with
+;; this work for additional information regarding copyright ownership.
+;; The ASF licenses this file to You under the Apache License, Version 2.0
+;; (the "License"); you may not use this file except in compliance with
+;; the License. You may obtain a copy of the License at
+;;
+;; http://www.apache.org/licenses/LICENSE-2.0
+;;
+;; Unless required by applicable law or agreed to in writing, software
+;; distributed under the License is distributed on an "AS IS" BASIS,
+;; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+;; See the License for the specific language governing permissions and
+;; limitations under the License.
(ns kafka.print-test
(:use (kafka types print)
clojure.test))
Modified: incubator/kafka/trunk/clients/clojure/test/kafka/serializable_test.clj
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/clojure/test/kafka/serializable_test.clj?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/clojure/test/kafka/serializable_test.clj (original)
+++ incubator/kafka/trunk/clients/clojure/test/kafka/serializable_test.clj Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+;; Licensed to the Apache Software Foundation (ASF) under one or more
+;; contributor license agreements. See the NOTICE file distributed with
+;; this work for additional information regarding copyright ownership.
+;; The ASF licenses this file to You under the Apache License, Version 2.0
+;; (the "License"); you may not use this file except in compliance with
+;; the License. You may obtain a copy of the License at
+;;
+;; http://www.apache.org/licenses/LICENSE-2.0
+;;
+;; Unless required by applicable law or agreed to in writing, software
+;; distributed under the License is distributed on an "AS IS" BASIS,
+;; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+;; See the License for the specific language governing permissions and
+;; limitations under the License.
(ns kafka.serializable-test
(:use (kafka types serializable)
clojure.test))
Modified: incubator/kafka/trunk/clients/cpp/build-aux/install-sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/cpp/build-aux/install-sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/cpp/build-aux/install-sh (original)
+++ incubator/kafka/trunk/clients/cpp/build-aux/install-sh Fri Oct 7 19:51:28 2011
@@ -1,4 +1,18 @@
#!/bin/sh
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
# install - install a program, script, or datafile
scriptversion=2009-04-28.21; # UTC
Modified: incubator/kafka/trunk/clients/cpp/build-aux/ltmain.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/cpp/build-aux/ltmain.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/cpp/build-aux/ltmain.sh (original)
+++ incubator/kafka/trunk/clients/cpp/build-aux/ltmain.sh Fri Oct 7 19:51:28 2011
@@ -1,4 +1,18 @@
# Generated from ltmain.m4sh.
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
# ltmain.sh (GNU libtool) 2.2.6b
# Written by Gordon Matzigkeit <go...@gnu.ai.mit.edu>, 1996
Modified: incubator/kafka/trunk/clients/php/src/examples/autoloader.php
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/php/src/examples/autoloader.php?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/php/src/examples/autoloader.php (original)
+++ incubator/kafka/trunk/clients/php/src/examples/autoloader.php Fri Oct 7 19:51:28 2011
@@ -1,3 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
<?php
spl_autoload_register(function($className)
Modified: incubator/kafka/trunk/clients/php/src/examples/consume.php
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/php/src/examples/consume.php?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/php/src/examples/consume.php (original)
+++ incubator/kafka/trunk/clients/php/src/examples/consume.php Fri Oct 7 19:51:28 2011
@@ -1,4 +1,21 @@
#!/usr/bin/php
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
<?php
set_include_path(
Modified: incubator/kafka/trunk/clients/php/src/examples/produce.php
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/php/src/examples/produce.php?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/php/src/examples/produce.php (original)
+++ incubator/kafka/trunk/clients/php/src/examples/produce.php Fri Oct 7 19:51:28 2011
@@ -1,4 +1,21 @@
#!/usr/bin/php
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
<?php
set_include_path(
Modified: incubator/kafka/trunk/clients/php/src/tests/Kafka/BoundedByteBuffer/ReceiveTest.php
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/php/src/tests/Kafka/BoundedByteBuffer/ReceiveTest.php?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/php/src/tests/Kafka/BoundedByteBuffer/ReceiveTest.php (original)
+++ incubator/kafka/trunk/clients/php/src/tests/Kafka/BoundedByteBuffer/ReceiveTest.php Fri Oct 7 19:51:28 2011
@@ -1,3 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
<?php
if (!defined('PRODUCE_REQUEST_ID')) {
define('PRODUCE_REQUEST_ID', 0);
Modified: incubator/kafka/trunk/clients/php/src/tests/Kafka/BoundedByteBuffer/SendTest.php
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/php/src/tests/Kafka/BoundedByteBuffer/SendTest.php?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/php/src/tests/Kafka/BoundedByteBuffer/SendTest.php (original)
+++ incubator/kafka/trunk/clients/php/src/tests/Kafka/BoundedByteBuffer/SendTest.php Fri Oct 7 19:51:28 2011
@@ -1,3 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
<?php
/**
Modified: incubator/kafka/trunk/clients/php/src/tests/Kafka/EncoderTest.php
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/php/src/tests/Kafka/EncoderTest.php?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/php/src/tests/Kafka/EncoderTest.php (original)
+++ incubator/kafka/trunk/clients/php/src/tests/Kafka/EncoderTest.php Fri Oct 7 19:51:28 2011
@@ -1,3 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
<?php
if (!defined('PRODUCE_REQUEST_ID')) {
define('PRODUCE_REQUEST_ID', 0);
Modified: incubator/kafka/trunk/clients/php/src/tests/Kafka/FetchRequestTest.php
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/php/src/tests/Kafka/FetchRequestTest.php?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/php/src/tests/Kafka/FetchRequestTest.php (original)
+++ incubator/kafka/trunk/clients/php/src/tests/Kafka/FetchRequestTest.php Fri Oct 7 19:51:28 2011
@@ -1,3 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
<?php
/**
Modified: incubator/kafka/trunk/clients/php/src/tests/Kafka/MessageTest.php
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/php/src/tests/Kafka/MessageTest.php?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/php/src/tests/Kafka/MessageTest.php (original)
+++ incubator/kafka/trunk/clients/php/src/tests/Kafka/MessageTest.php Fri Oct 7 19:51:28 2011
@@ -1,3 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
<?php
/**
Modified: incubator/kafka/trunk/clients/php/src/tests/Kafka/ProducerTest.php
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/php/src/tests/Kafka/ProducerTest.php?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/php/src/tests/Kafka/ProducerTest.php (original)
+++ incubator/kafka/trunk/clients/php/src/tests/Kafka/ProducerTest.php Fri Oct 7 19:51:28 2011
@@ -1,3 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
<?php
/**
Modified: incubator/kafka/trunk/clients/php/src/tests/bootstrap.php
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/php/src/tests/bootstrap.php?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/php/src/tests/bootstrap.php (original)
+++ incubator/kafka/trunk/clients/php/src/tests/bootstrap.php Fri Oct 7 19:51:28 2011
@@ -1,3 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
<?php
function test_autoload($className)
Modified: incubator/kafka/trunk/clients/ruby/lib/kafka.rb
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/ruby/lib/kafka.rb?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/ruby/lib/kafka.rb (original)
+++ incubator/kafka/trunk/clients/ruby/lib/kafka.rb Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
require 'socket'
require 'zlib'
Modified: incubator/kafka/trunk/clients/ruby/lib/kafka/batch.rb
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/ruby/lib/kafka/batch.rb?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/ruby/lib/kafka/batch.rb (original)
+++ incubator/kafka/trunk/clients/ruby/lib/kafka/batch.rb Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
module Kafka
class Batch
attr_accessor :messages
Modified: incubator/kafka/trunk/clients/ruby/lib/kafka/consumer.rb
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/ruby/lib/kafka/consumer.rb?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/ruby/lib/kafka/consumer.rb (original)
+++ incubator/kafka/trunk/clients/ruby/lib/kafka/consumer.rb Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
module Kafka
class Consumer
Modified: incubator/kafka/trunk/clients/ruby/lib/kafka/error_codes.rb
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/ruby/lib/kafka/error_codes.rb?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/ruby/lib/kafka/error_codes.rb (original)
+++ incubator/kafka/trunk/clients/ruby/lib/kafka/error_codes.rb Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
module Kafka
module ErrorCodes
NO_ERROR = 0
Modified: incubator/kafka/trunk/clients/ruby/lib/kafka/io.rb
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/ruby/lib/kafka/io.rb?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/ruby/lib/kafka/io.rb (original)
+++ incubator/kafka/trunk/clients/ruby/lib/kafka/io.rb Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
module Kafka
module IO
attr_accessor :socket, :host, :port
Modified: incubator/kafka/trunk/clients/ruby/lib/kafka/message.rb
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/ruby/lib/kafka/message.rb?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/ruby/lib/kafka/message.rb (original)
+++ incubator/kafka/trunk/clients/ruby/lib/kafka/message.rb Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
module Kafka
# A message. The format of an N byte message is the following:
Modified: incubator/kafka/trunk/clients/ruby/lib/kafka/producer.rb
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/ruby/lib/kafka/producer.rb?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/ruby/lib/kafka/producer.rb (original)
+++ incubator/kafka/trunk/clients/ruby/lib/kafka/producer.rb Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
module Kafka
class Producer
Modified: incubator/kafka/trunk/clients/ruby/lib/kafka/request_type.rb
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/ruby/lib/kafka/request_type.rb?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/ruby/lib/kafka/request_type.rb (original)
+++ incubator/kafka/trunk/clients/ruby/lib/kafka/request_type.rb Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
module Kafka
module RequestType
PRODUCE = 0
Modified: incubator/kafka/trunk/clients/ruby/spec/batch_spec.rb
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/ruby/spec/batch_spec.rb?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/ruby/spec/batch_spec.rb (original)
+++ incubator/kafka/trunk/clients/ruby/spec/batch_spec.rb Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
require File.dirname(__FILE__) + '/spec_helper'
describe Batch do
Modified: incubator/kafka/trunk/clients/ruby/spec/consumer_spec.rb
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/ruby/spec/consumer_spec.rb?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/ruby/spec/consumer_spec.rb (original)
+++ incubator/kafka/trunk/clients/ruby/spec/consumer_spec.rb Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
require File.dirname(__FILE__) + '/spec_helper'
describe Consumer do
Modified: incubator/kafka/trunk/clients/ruby/spec/io_spec.rb
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/ruby/spec/io_spec.rb?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/ruby/spec/io_spec.rb (original)
+++ incubator/kafka/trunk/clients/ruby/spec/io_spec.rb Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
require File.dirname(__FILE__) + '/spec_helper'
class IOTest
Modified: incubator/kafka/trunk/clients/ruby/spec/kafka_spec.rb
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/ruby/spec/kafka_spec.rb?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/ruby/spec/kafka_spec.rb (original)
+++ incubator/kafka/trunk/clients/ruby/spec/kafka_spec.rb Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
require File.dirname(__FILE__) + '/spec_helper'
describe Kafka do
Modified: incubator/kafka/trunk/clients/ruby/spec/message_spec.rb
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/ruby/spec/message_spec.rb?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/ruby/spec/message_spec.rb (original)
+++ incubator/kafka/trunk/clients/ruby/spec/message_spec.rb Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
require File.dirname(__FILE__) + '/spec_helper'
describe Message do
Modified: incubator/kafka/trunk/clients/ruby/spec/producer_spec.rb
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/ruby/spec/producer_spec.rb?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/ruby/spec/producer_spec.rb (original)
+++ incubator/kafka/trunk/clients/ruby/spec/producer_spec.rb Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
require File.dirname(__FILE__) + '/spec_helper'
describe Producer do
Modified: incubator/kafka/trunk/clients/ruby/spec/spec_helper.rb
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/clients/ruby/spec/spec_helper.rb?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/clients/ruby/spec/spec_helper.rb (original)
+++ incubator/kafka/trunk/clients/ruby/spec/spec_helper.rb Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
require 'rubygems'
require 'kafka'
Modified: incubator/kafka/trunk/config/consumer.properties
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/config/consumer.properties?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/config/consumer.properties (original)
+++ incubator/kafka/trunk/config/consumer.properties Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
# see kafka.consumer.ConsumerConfig for more details
# zk connection string
Modified: incubator/kafka/trunk/config/log4j.properties
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/config/log4j.properties?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/config/log4j.properties (original)
+++ incubator/kafka/trunk/config/log4j.properties Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
log4j.rootLogger=INFO, stdout
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
Modified: incubator/kafka/trunk/config/server.properties
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/config/server.properties?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/config/server.properties (original)
+++ incubator/kafka/trunk/config/server.properties Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
# see kafka.server.KafkaConfig for additional details and defaults
# the id of the broker
Modified: incubator/kafka/trunk/config/zookeeper.properties
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/config/zookeeper.properties?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/config/zookeeper.properties (original)
+++ incubator/kafka/trunk/config/zookeeper.properties Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
# the directory where the snapshot is stored.
dataDir=/tmp/zookeeper
# the port at which the clients will connect
Modified: incubator/kafka/trunk/contrib/hadoop-consumer/copy-jars.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/contrib/hadoop-consumer/copy-jars.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/contrib/hadoop-consumer/copy-jars.sh (original)
+++ incubator/kafka/trunk/contrib/hadoop-consumer/copy-jars.sh Fri Oct 7 19:51:28 2011
@@ -1,4 +1,18 @@
#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
if [ $# -lt 1 ];
then
Modified: incubator/kafka/trunk/contrib/hadoop-consumer/hadoop-setup.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/contrib/hadoop-consumer/hadoop-setup.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/contrib/hadoop-consumer/hadoop-setup.sh (original)
+++ incubator/kafka/trunk/contrib/hadoop-consumer/hadoop-setup.sh Fri Oct 7 19:51:28 2011
@@ -1,4 +1,18 @@
#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
hadoop=${HADOOP_HOME}/bin/hadoop
Modified: incubator/kafka/trunk/contrib/hadoop-consumer/run-class.sh
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/contrib/hadoop-consumer/run-class.sh?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/contrib/hadoop-consumer/run-class.sh (original)
+++ incubator/kafka/trunk/contrib/hadoop-consumer/run-class.sh Fri Oct 7 19:51:28 2011
@@ -1,4 +1,18 @@
#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
if [ $# -lt 1 ];
then
Modified: incubator/kafka/trunk/contrib/hadoop-consumer/test/test.properties
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/contrib/hadoop-consumer/test/test.properties?rev=1180185&r1=1180184&r2=1180185&view=diff
==============================================================================
--- incubator/kafka/trunk/contrib/hadoop-consumer/test/test.properties (original)
+++ incubator/kafka/trunk/contrib/hadoop-consumer/test/test.properties Fri Oct 7 19:51:28 2011
@@ -1,3 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
# name of test topic
kafka.etl.topic=SimpleTestEvent