Pull request #20: DevelopmentMerge in ODY_WRAP/kafka from development to master
* commit '3c83afa31d12451ab7a39605fc2919abcc0e6f3f':
start writing to buffer when marker was received
new implementation of kafka transport handler for state management
Pull request #19: State managementMerge in ODY_WRAP/kafka from state_management to development
* commit '9f0c420ead5f6677724a8d4f8f2b33737d063c84':
start writing to buffer when marker was received
new implementation of kafka transport handler for state management
Pull request #18: Removed plugin dependencyMerge in ODY_WRAP/kafka from development to master
* commit '144384ea2db1c3297e1468a9cad82698c59259ca':
Removed plugin dependency
Pull request #17: DevelopmentMerge in ODY_WRAP/kafka from development to master
* commit 'd93f13c167cd4b402fe8292f019e6124e0c1b472':
Odysseus_dev update
Removed plugins
Pull request #16: ODY-2189: Properties cannot be static!Merge in ODY_WRAP/kafka from development to master
* commit '4ae4ec61742d87d374e00707f5e7d47d9a53a20a':
ODY-2189: Properties cannot be static!
Pull request #15: DevelopmentMerge in ODY_WRAP/kafka from development to master
* commit '06bf92ed2d0dc38cc37910400a4df12d6dd0fb06':
Scala not needed
Update to latest kafka libs
Pull request #14: DevelopmentMerge in ODY_WRAP/kafka from development to master
* commit '28baaa786cf7abb51b301098d1ab5cd7098b4d8b':
Submodule update
Set encoding
Allow to push prefs
Pull request #13: DevelopmentMerge in ODY_WRAP/kafka from development to master
* commit 'a62c3bd4de3ae8e19e2d022491767cdced01505c': (44 commits)
Change to only send offsets and commit and begin a new transaction if the offset list is not empty.
Change default reading of operator states to false and only set explicitly or with a according mode.
Move parsing of isolationLevel to initConsumer
Fix checking mapIdState...
Pull request #12: Feature/ODY-2081 up and downstream commitment of kafka topics with marker synchronisation onMerge in ODY_WRAP/kafka from feature/ODY-2081-up-and-downstream-commitment-of-kafka-topics-with-marker-synchronisation-on to development
* commit '126fe07d8b0f932be3d35d9dac1dae3cc4111e20': (38 commits)
Change to only send offsets and commit and begin a new transaction if the offset list is not empty.
Change default reading of operator states to false and only set explicitly or with a acco...
Change to only send offsets and commit and begin a new transaction if the offset list is not empty.Fix logging general exception in KafkaTransportHandler.
Fix read operator states with lower cased read_committed.
Change default reading of operator states to false and only set explicitly or with a according mode.Fix to not set transactional.id when in no TransactionMode.
Make sure to not set transactional.id in consumer properties.
Fix checking mapIdState in method mergeMapIdState of Marker.Fix by removing now faulty @Override annotations.
Add method processOperator method to Marker which sets initial state of saves the state in marker state.
Renamed static final variables in KafkaTransportHandler to upper case.Use parsing to IsolationLevel enum.
Change to use option.getBoolean for Boolean types instead of own parsing.
Change to use initial dynamic getting of (de)serializers in static final variables.
Add kafka common to imported packages.
Change to save operator states as map and not as keys mapped to states on one topic.Change the get and setByteArray methods in Marker so (de)serialize the whole id states map instead of only the states.
Fix to use the consumer position for commitment of the operator states map.
Merge branch 'feature/ODY-2081-up-and-downstream-commitment-of-kafka-topics-with-marker-synchronisation-on' of ssh://git.swl.informatik.uni-oldenburg.de:7999/ody_wrap/kafka into feature/ODY-2081-up-and-downstream-commitment-of-kafka-topics-with-marker-synchronisation-on
Remove unnecessary, not used mapQueryIdOperatorStatesOffset.Change mapQueryIdOperatorStates to be ConcurrentHashMap and omit the explicit synchronization.
Change extraction of values to use the owner as the po.
Add parsing of markerSendingDelay from userParameter and set it as delay between marker sending.
Change to not send the operator states offset when no operator states are read.
Use the operatorStatesTopic from the set userParam and not over the c...
Override transactional.id with globalQueryId if present.Refactor extractValuesFromProtocolHandler to extractValuesFromOwner.
Change getting OperatorOwner outside of extraction method.
Set protocolHandler in the init method.
Merge branch 'feature/ODY-2081-up-and-downstream-commitment-of-kafka-topics-with-marker-synchronisation-on' of ssh://git.swl.informatik.uni-oldenburg.de:7999/ody_wrap/kafka into feature/ODY-2081-up-and-downstream-commitment-of-kafka-topics-with-marker-synchronisation-on
Fix not extract globalQueryId when sending and initially consumer-commit 0 for transaction.Fix not trying to extract globalQueryId by KafkaTransportHandler.send, it will be gotten over ConsumerRunner.
Add comment, that no flushing is needed for transactional committing.
Fix not using setProperty but put for Properties instead.
Fix setting operatorStateOffset to 0 for commiting and checking on '>= 0' when setting the offset because committed reading needs to have committed something i...
Marco Grawunder
Tom Glaeseker