How can I write streaming Dataflow pipelines that support schema evolution? I'm building some data streaming pipelines that read from Kafka and write to various sinks using Google Cloud Dataflow. The pipeline looks something like this (simplified). // Example pipeline that writes to BigQuery. Pipeline.create(options) .apply(KafkaIO.read().withTopic(options.topic)) .apply(/* Convert to a Row type */) .setRowSchema(schemaRegistry.lookup(options.topic)) .apply( BigQueryIO.write() .useBeamSchema()...

Dagger 2 @Singleton does not working in LibGDX (kotlin) I'm trying to write a game on Android with dagger 2 features. I have a problem with @Singleton. I have created the module: @Module class SharedModule { @Singleton @Provides fun getDeviceService(): DeviceService = DeviceService() @Provides @Singleton fun getAssetsService(): AssetsService = AssetsService() @Singleton @Provides fun getGameService(): GameService = GameService() } and the component @Singleton @Component(modules = [SharedModule::class])...

Android navigation icon is not vertically aligned when using custom toolbar I have used a custom toolbar class so i can align the title to the right and every thing works fine except the navigation back icon is not vertically aligned and this is the custom toolbar class class RTLToolbar @JvmOverloads constructor( context: Context, attrs: AttributeSet? = null, defStyleAttr: Int = 0 ) : Toolbar(context, attrs, defStyleAttr) { override fun onLayout(changed: Boolean, l: Int, t: Int,...

Kotlin JVM function to compare part of a ByteArray to a CharSequence via a Charset Is there any Kotlin JVM function to compare part of a ByteArray to a CharSequence via a Charset? e.g, something like ByteArray.matches(startInclusive: Int, other: CharSequence, charset: Charset): Boolean: "abcdef".toByteArray().matches(0, "abc", UTF_8) I don't see any need to create a String from the ByteArray to do the comparison. I can write the utility method myself, but I don't want to reinvent the wheel…

android studio 3.6.1 ubuntu 19.10 first try: A problem occurred configuring root project I installed android studio for ubuntu 19.10 earlier today and android studio downloaded sdk and other stuff itself and it gets ready so i started default project to build gradle and maven. i get this A problem occurred configuring root project 'My Application'. > Could not resolve all artifacts for configuration ':classpath'. > Could not resolve org.jetbrains.kotlinkotlin gradle plugin1.3.61. Required by: project : > No cached version of...

Cannot deserialize Timestamp object from Firebase to RecyclerView I am currently trying to build a social media application where I can order my feeds by timestamp. However, when I try building the FirebaseRecyclerOptions for the RecyclerView, I get an error saying a String couldn't be converted to Timestamp: Could not deserialize object. Failed to convert value of type java.lang.String to Timestamp (found in field 'timestamp') I have made sure my Timestamp objects are from the Firebase package. I have no idea what the issue is and would appreciate...

doAsync does not work in a Fragment class I am using Kotlin language for the android application I am building and I use doAsync for getting data from a JSON. First I did it in the MainActivity which extends AppCompatibility() and it worked, but now I also have to get some data from another JSON in another class which extends Fragment() and apparently it does not work because it does not enter inside the Async method when I debug the application. This is the code I have: class CreatePayment : Fragment(), View.OnClickListener {...

Pros and Cons with installing Kotlin standalone compiler instead of using IntelliJ Kotlin plugin? i understand that i can use Kotlin Plugin comes with IntelliJ but i can also install Kotlin standalone compiler. Is there any pros/cons using standalone vs IntelliJ own integrated? Thanks for the help!

Android NfcAdapter deprecated? According to Android: NFC basics, the two ways of sending a NDEF message through NFC is by using either setNdefPushMessage or setNdefPushMessageCallback. But both are deprecated in API level 29. Does this mean that Android is deprecating NFC, or, at least, NDEF? What should I use for sending/receiving a NDEF message?

why i cant insert data into my database file using kotlin language? I have a big problem ,when i try to insert the data into my database he sends me a error message like this one: 2020-03-03 105137.862 30520-30520/com.example.jetpackteste E/SQLiteDatabase: Error inserting Morada= Codigo_postal2= Telefone=0 Localidade= ID_cliente=0 Pais=ERU Nome_cliente= Codigo_postal=0 Contribuinte= android.database.sqlite.SQLiteConstraintException: UNIQUE constraint failed: cliente.ID_cliente (code 1555 SQLITE_CONSTRAINT_PRIMARYKEY[1555]) at...

Cross icon in outside of BottomSheetDialog According to our latest design, I should put the close icon in the outside of BottomSheetDialog (Yes, I know that it is absolutely useless). Is there any way to do this?

Kotlinx duplicate keys I have a json structure with duplicate keys, and I'm trying to figure out how to turn this into a List but when trying to use a DeserializationStrategy I first must decode to a JsonObject which removes the duplicated keys i.e. object JsonArrayToStringMapDeserializer : DeserializationStrategy { override val descriptor = SerialClassDescImpl("JsonMap") override fun deserialize(decoder: Decoder): List { val input = decoder as? JsonInput ?: throw...

CollapsingToolbar + RecyclerView + NavigationDrawer (is this possible yet?) I'm trying to implement a collapsing toolbar with a NavigationView & RecyclerView but regardless of how far within the RecyclerView I scroll, the Toolbar just won't collapse! As of Spring 2020, is this possible at all? I really hate having to stretch my thumb to reach the top few items in my RecyclerView as the screen size is already big + I don't want to use both hands to scroll through the RecyclerView. Please note that if there's no proper working solution for this then I'll have no choice...

Could not get unknown property 'GROUP' for object of type org.gradle.api.publication.maven.internal.deployer.DefaultGroovyMavenDeployer I want to use blackfizz/EazeGraph in my project and for that I downloaded it and imported it as a module to my empty "hello world" Android project. I am using android studio v3.5.3 using sdk manager v26 and this is my app/build.gradle apply plugin: 'com.android.application' android { compileSdkVersion 29 buildToolsVersion "29.0.2" defaultConfig { applicationId "com.abdsafi.testchartline" minSdkVersion 21 targetSdkVersion 29 versionCode 1...

Getting Error while fetching contact in android(Kotlin) - Failed to read row 0, column -1 from a CursorWindow which has 1 rows, 36 columns Here is my code in kotlin override fun onActivityResult(requestCode: Int, resultCode: Int, data: Intent?) { super.onActivityResult(requestCode, resultCode, data) if (resultCode == Activity.RESULT_OK) { // Check for the request code, we are usign multiple startActivityForReslut when (requestCode) { PICK_CONTACT -> { var cursor: Cursor? = null try { val contactUri:Uri=data!!.data!!...

How to handle special character in Kotlin Android I have a String which I am getting from API (no control over it). When the String contains a special character like apastrophe, it will be converted to something else. It looks something like this text_view.text = "Hannah's Law" When displayed on Android, it will be: Hannah's Law I tried to convert the String to byteArray and then encode to UTF-8 but no luck: val byteArray = template.execute(bindingDictionary).toByteArray() // This is the Actual String...

Why is kotlin stream evaluating an .all predicate to true where the first Iterable is empty I have a List of objects. importerResponse.applications is empty (size=0) This is my code: val isDeployed = importerResponse.applications .flatMap(Application::instances) .map(Instance::state) .all { state -> DEPLOYED == state } isDeployed is true in this case. How can this be? I want it to resolve into false if applications is empty.

"No converter found for return value" when running Spring Boot MockMvc test I'm trying to create a MockMvc test of a Spring Boot controller. I specifically do not want the entire application context to be spun up, so I am restricting the context to the controller in question. However, the test fails with a 500 with the following log output: 2020-03-03 130406.904 WARN 8207 --- [ main] .w.s.m.s.DefaultHandlerExceptionResolver : Resolved [org.springframework.http.converter.HttpMessageNotWritableException: No converter found for return value of type: class...

How to align six ImageView with custom shape to complete a full circle I have 6 ImageView that are aligned together in full circle, which means each ImagView must have a degree of 60, but I couldn't get this exact shape using drawable XML and even if I could, how could I align them to together in to complete a circle? (see the picture below) PS: I'm using this library to mask the shape with the...

Trying to create Stadium seating layout with portions [closed] Here is the layout which I want to create. I tried so many ways through canvas and recycler view but can't make it happen. If anyone knows how to do it kindly share your views and code for some extent.

Android Kotlin : Sort data in adapter and keeping translation I'm using the following adapter to create a Spinner dropdown. My adapter only display one text for each item. This item is translated. This code works well but at the end the spinner contains values that are not sorted alphabetically. How can I modify the code to sort the data and keeping the translation ? Activity.kt: val spinner: Spinner = findViewById(R.id.units_cars) val carsArray = resources.getStringArray(R.array.cars_array) spinner.adapter = CarsDropdownAdapter(this, carsArray)...

How and when to initialize inherited, custom view's constructors the right way? I am trying to create a custom view hierarchy for Android in Kotlin, and here is what I would like to achieve: An un-instantiatable class TileView, which defines a custom view with a label, some text content, and an icon - basically defining the layout of a tile. An un-instantiatable class TextInputView extending the TileView, which opens a dialog, allowing for text input to the parent's text content view. An instantiable class CommentView extending the TextInputView, to let the user write a...

Tasks.whenAll doesn't work on Firebase FileDownloadTasks My goal is to recognize the end of all current FileDownloadTasks, unfortunately, compilator doesn't like that, in other questions using whenAll() solved the problem. val tasks = FirebaseStorage.getInstance().reference.activeDownloadTasks Tasks.whenAll(tasks){ Log.d("loadGlobalData", "Successful operation") }

Incorrect long type I have the following query in Hibernate: val em: EntityManager = ... em.createQuery("SELECT id FROM Segment s WHERE $condition", Long::class.java) val result = q.resultList When running it I get the following error: Type specified for TypedQuery [long] is incompatible with query return type [class java.lang.Long]

Dark notification on Android 10 with Remote View Getting Dark (black) notification as per image shown here when I changed display mode to Dark in Android 10. I tried to change text color but it is not reflating. I am using Remote view to create custom notification. How to change remote content view text colors just for Dark mode? Here is my code: val contentViewBig = RemoteViews(context.applicationContext.packageName, R.layout.design_custom_notification) contentViewBig.setTextViewText(R.id.tvNotificationTitle,...

Something wrong with asynchronous functions I am new to Kotlin and is currently developing a quiz app in Android studio. I am fetching questions from an API (Open Trivia Database). I am using a progressbar to display time for the users when they answering questions. I am currently using callbacks to retrieve variables and to know when my functions is finished executing. This is my functions to fetch data from API: private fun fetchTokens(callback: (String)->Unit){ val tokenUrl =...

How to structure DTO class in a clean architecture project with parcelize? I'm working on an Android app in Kotlin and am trying to implement Clean Architecture with viewmodels, repositories, datasources, interfaces etc. Right now I have a DTO class that I'm parsing with Retrofit: @Parcelize data class NewsArticleDto( val author: String, val title: String, val description: String, val url: String, val urlToImage: String, val publishedAt: String, val content: String ) : Parcelable I would like to have an interactor called "GetNews" get the data from...

Spring Boot controller test with TestRestTemplate always fails with endpoints returning 404 I am trying to create a test of a Spring Boot controller using TestRestTemplate. It is a requirement that only what is absolutely required for the controller be included in the test context, so spinning up the entire application context for the test is not an option. Currently the test fails due to the endpoint returning 404. The endpoint works correctly in production. It appears that the controller is not being registered with the web servlet. The controller appears as follows:...

What is the difference between await functions (coroutine) and subscribe on Reactor I'm using Kotlin + Reactor (Mono and Flux) and I wanna know the difference between using await...() (from kotlin-coroutines-reactive) function and subscribe() (from Reactor). I brought two examples to show what I'm trying to do. Example 1 (with await function): @Test internal fun test() = runBlockingTest { Mono.error(IllegalStateException("exception"))...

Manifest merger failed when i add third party library I am getting these errors when build starts. Manifest merger failed : uses-sdk:minSdkVersion 19 cannot be smaller than version 21 declared in library [com.github.ChiliLabsChiliPhotoPicker0.3.1] C:\Users\DELL.gradle\caches\transforms-2\files- strong text 2.1\b034ff3194e7ba4b9353c2b9bbcaf626\ChiliPhotoPicker-0.3.1\AndroidManifest.xml as the library might be using APIs not available in 19 Suggestion: use a compatible library with a minSdk of at most 19, or increase this...