This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a change to branch kafka_2.0
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
from 7db18ae Make kafka 2.0 working with hardcoded configs
add 83a7510 Trying to make kafka build with a profile
No new revisions were added by this update.
Summary of changes:
.../kafka/server/KafkaDataServerStartable.java | 2 ++
...inot.core.realtime.stream.StreamConsumerFactory | 1 +
.../kafka/KafkaPartitionLevelConsumerTest.java | 2 +-
.../kafka2/server/KafkaDataServerStartable.java | 2 ++
...inot.core.realtime.stream.StreamConsumerFactory | 1 +
.../realtime/impl/kafka}/KafkaStarterUtils.java | 17 ++++++++----
pinot-distribution/pinot-assembly.xml | 5 ++++
pinot-integration-tests/pom.xml | 7 +----
.../tests/BaseClusterIntegrationTest.java | 2 +-
.../tests/ClusterIntegrationTestUtils.java | 2 +-
.../ControllerPeriodicTasksIntegrationTests.java | 2 +-
...lakyConsumerRealtimeClusterIntegrationTest.java | 2 +-
.../tests/HybridClusterIntegrationTest.java | 2 +-
...ridClusterIntegrationTestCommandLineRunner.java | 2 +-
.../tests/RealtimeClusterIntegrationTest.java | 2 +-
pinot-perf/pom.xml | 2 +-
.../perf/BenchmarkRealtimeConsumptionSpeed.java | 2 +-
.../org/apache/pinot/perf/RealtimeStressTest.java | 2 +-
pinot-tools/pom.xml | 32 +++++++++++++++++++++-
.../org/apache/pinot/tools/HybridQuickstart.java | 5 ++--
.../org/apache/pinot/tools/RealtimeQuickStart.java | 2 +-
.../tools/admin/command/StartKafkaCommand.java | 2 +-
.../admin/command/StreamAvroIntoKafkaCommand.java | 2 +-
.../pinot/tools/streams/AirlineDataStream.java | 2 +-
.../pinot/tools/streams/MeetupRsvpStream.java | 2 +-
.../airlineStats_realtime_table_config.json | 1 -
.../airlineStats_realtime_table_config.json | 1 -
.../meetupRsvp_realtime_table_config.json | 5 ++--
.../airlineStats_realtime_table_config.json | 0
.../meetupRsvp_realtime_table_config.json | 0
.../meetupRsvp_realtime_table_config.json | 5 ++--
pom.xml | 14 +++++++++-
32 files changed, 90 insertions(+), 40 deletions(-)
create mode 100644
pinot-connectors/pinot-connector-kafka-0.9/src/main/resources/META-INF/services/org.apache.pinot.core.realtime.stream.StreamConsumerFactory
create mode 100644
pinot-connectors/pinot-connector-kafka-2.0/src/main/resources/META-INF/services/org.apache.pinot.core.realtime.stream.StreamConsumerFactory
rename {pinot-tools/src/main/java/org/apache/pinot/tools =>
pinot-connectors/pinot-connector-kafka-base/src/main/java/org/apache/pinot/core/realtime/impl/kafka}/KafkaStarterUtils.java
(87%)
copy pinot-tools/src/main/resources/sample_data/{ =>
kafka_0.9}/airlineStats_realtime_table_config.json (91%)
copy pinot-tools/src/main/resources/sample_data/{ =>
kafka_0.9}/meetupRsvp_realtime_table_config.json (82%)
copy pinot-tools/src/main/resources/sample_data/{ =>
kafka_2.0}/airlineStats_realtime_table_config.json (100%)
copy pinot-tools/src/main/resources/sample_data/{ =>
kafka_2.0}/meetupRsvp_realtime_table_config.json (100%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
