You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by rg...@apache.org on 2023/03/20 07:01:01 UTC
[flume] branch trunk updated (88d2b95a6 -> a95d957bb)
This is an automated email from the ASF dual-hosted git repository.
rgoers pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/flume.git
from 88d2b95a6 FLUME-3456 - Create Bill of Materials. FLUME 3455 - Move Twitter source to its own repo
add a95d957bb FLUME-3457 - Move Kafka components to their own repo
No new revisions were added by this update.
Summary of changes:
flume-bom/pom.xml | 34 +-
flume-ng-channels/flume-kafka-channel/pom.xml | 93 --
.../apache/flume/channel/kafka/KafkaChannel.java | 718 ----------------
.../channel/kafka/KafkaChannelConfiguration.java | 59 --
.../channel/kafka/TestBasicFunctionality.java | 220 -----
.../flume/channel/kafka/TestKafkaChannelBase.java | 272 ------
.../channel/kafka/TestOffsetsAndMigration.java | 77 --
.../flume/channel/kafka/TestParseAsFlumeEvent.java | 132 ---
.../apache/flume/channel/kafka/TestPartitions.java | 179 ----
.../apache/flume/channel/kafka/TestRollback.java | 105 ---
.../src/test/resources/kafka-server.properties | 133 ---
.../src/test/resources/keystorefile.jks | Bin 1294 -> 0 bytes
.../src/test/resources/log4j2.xml | 72 --
.../src/test/resources/truststorefile.jks | Bin 887 -> 0 bytes
.../src/test/resources/zookeeper.properties | 20 -
flume-ng-channels/pom.xml | 1 -
flume-ng-dist/pom.xml | 8 +-
flume-ng-sinks/flume-ng-kafka-sink/pom.xml | 134 ---
.../org/apache/flume/sink/kafka/KafkaSink.java | 490 -----------
.../flume/sink/kafka/KafkaSinkConstants.java | 62 --
.../org/apache/flume/sink/kafka/TestConstants.java | 31 -
.../org/apache/flume/sink/kafka/TestKafkaSink.java | 839 -------------------
.../apache/flume/sink/kafka/util/KafkaLocal.java | 53 --
.../org/apache/flume/sink/kafka/util/TestUtil.java | 294 -------
.../flume/sink/kafka/util/ZooKeeperLocal.java | 62 --
.../src/test/resources/kafka-server.properties | 131 ---
.../src/test/resources/keystorefile.jks | Bin 1294 -> 0 bytes
.../src/test/resources/log4j2.xml | 72 --
.../src/test/resources/testutil.properties | 3 -
.../src/test/resources/truststorefile.jks | Bin 887 -> 0 bytes
.../src/test/resources/zookeeper.properties | 20 -
flume-ng-sinks/pom.xml | 1 -
flume-ng-sources/flume-kafka-source/pom.xml | 102 ---
.../org/apache/flume/source/kafka/KafkaSource.java | 539 ------------
.../flume/source/kafka/KafkaSourceConstants.java | 57 --
.../source/kafka/KafkaSourceEmbeddedKafka.java | 209 -----
.../source/kafka/KafkaSourceEmbeddedZookeeper.java | 70 --
.../apache/flume/source/kafka/TestKafkaSource.java | 932 ---------------------
.../src/test/resources/keystorefile.jks | Bin 1294 -> 0 bytes
.../src/test/resources/log4j2.xml | 31 -
.../src/test/resources/truststorefile.jks | Bin 887 -> 0 bytes
flume-ng-sources/pom.xml | 1 -
flume-parent/pom.xml | 270 +-----
flume-shared/flume-shared-kafka-test/pom.xml | 86 --
.../shared/kafka/test/KafkaPartitionTestUtil.java | 220 -----
.../flume/shared/kafka/test/PartitionOption.java | 25 -
.../shared/kafka/test/PartitionTestScenario.java | 26 -
flume-shared/flume-shared-kafka/pom.xml | 54 --
.../apache/flume/shared/kafka/KafkaSSLUtil.java | 75 --
.../flume/shared/kafka/KafkaSSLUtilTest.java | 174 ----
flume-shared/pom.xml | 40 -
pom.xml | 1 -
52 files changed, 32 insertions(+), 7195 deletions(-)
delete mode 100644 flume-ng-channels/flume-kafka-channel/pom.xml
delete mode 100644 flume-ng-channels/flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java
delete mode 100644 flume-ng-channels/flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannelConfiguration.java
delete mode 100644 flume-ng-channels/flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestBasicFunctionality.java
delete mode 100644 flume-ng-channels/flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestKafkaChannelBase.java
delete mode 100644 flume-ng-channels/flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestOffsetsAndMigration.java
delete mode 100644 flume-ng-channels/flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestParseAsFlumeEvent.java
delete mode 100644 flume-ng-channels/flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestPartitions.java
delete mode 100644 flume-ng-channels/flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestRollback.java
delete mode 100644 flume-ng-channels/flume-kafka-channel/src/test/resources/kafka-server.properties
delete mode 100644 flume-ng-channels/flume-kafka-channel/src/test/resources/keystorefile.jks
delete mode 100644 flume-ng-channels/flume-kafka-channel/src/test/resources/log4j2.xml
delete mode 100644 flume-ng-channels/flume-kafka-channel/src/test/resources/truststorefile.jks
delete mode 100644 flume-ng-channels/flume-kafka-channel/src/test/resources/zookeeper.properties
delete mode 100644 flume-ng-sinks/flume-ng-kafka-sink/pom.xml
delete mode 100644 flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java
delete mode 100644 flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSinkConstants.java
delete mode 100644 flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/TestConstants.java
delete mode 100644 flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/TestKafkaSink.java
delete mode 100644 flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/util/KafkaLocal.java
delete mode 100644 flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/util/TestUtil.java
delete mode 100644 flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/util/ZooKeeperLocal.java
delete mode 100644 flume-ng-sinks/flume-ng-kafka-sink/src/test/resources/kafka-server.properties
delete mode 100644 flume-ng-sinks/flume-ng-kafka-sink/src/test/resources/keystorefile.jks
delete mode 100644 flume-ng-sinks/flume-ng-kafka-sink/src/test/resources/log4j2.xml
delete mode 100644 flume-ng-sinks/flume-ng-kafka-sink/src/test/resources/testutil.properties
delete mode 100644 flume-ng-sinks/flume-ng-kafka-sink/src/test/resources/truststorefile.jks
delete mode 100644 flume-ng-sinks/flume-ng-kafka-sink/src/test/resources/zookeeper.properties
delete mode 100644 flume-ng-sources/flume-kafka-source/pom.xml
delete mode 100644 flume-ng-sources/flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java
delete mode 100644 flume-ng-sources/flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSourceConstants.java
delete mode 100644 flume-ng-sources/flume-kafka-source/src/test/java/org/apache/flume/source/kafka/KafkaSourceEmbeddedKafka.java
delete mode 100644 flume-ng-sources/flume-kafka-source/src/test/java/org/apache/flume/source/kafka/KafkaSourceEmbeddedZookeeper.java
delete mode 100644 flume-ng-sources/flume-kafka-source/src/test/java/org/apache/flume/source/kafka/TestKafkaSource.java
delete mode 100644 flume-ng-sources/flume-kafka-source/src/test/resources/keystorefile.jks
delete mode 100644 flume-ng-sources/flume-kafka-source/src/test/resources/log4j2.xml
delete mode 100644 flume-ng-sources/flume-kafka-source/src/test/resources/truststorefile.jks
delete mode 100644 flume-shared/flume-shared-kafka-test/pom.xml
delete mode 100644 flume-shared/flume-shared-kafka-test/src/main/java/org/apache/flume/shared/kafka/test/KafkaPartitionTestUtil.java
delete mode 100644 flume-shared/flume-shared-kafka-test/src/main/java/org/apache/flume/shared/kafka/test/PartitionOption.java
delete mode 100644 flume-shared/flume-shared-kafka-test/src/main/java/org/apache/flume/shared/kafka/test/PartitionTestScenario.java
delete mode 100644 flume-shared/flume-shared-kafka/pom.xml
delete mode 100644 flume-shared/flume-shared-kafka/src/main/java/org/apache/flume/shared/kafka/KafkaSSLUtil.java
delete mode 100644 flume-shared/flume-shared-kafka/src/test/java/org/apache/flume/shared/kafka/KafkaSSLUtilTest.java
delete mode 100644 flume-shared/pom.xml